Skip to content

Commit d6f5dbf

Browse files
lukebakkenmergify[bot]
authored andcommitted
Fix combination of amqqueue:get_pid/1 and node/1
Fixes #8746 (cherry picked from commit acf25b4) (cherry picked from commit 41ce0f9)
1 parent e18b3b5 commit d6f5dbf

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

deps/rabbit/src/rabbit_classic_queue.erl

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -117,7 +117,7 @@ delete(Q, IfUnused, IfEmpty, ActingUser) when ?amqqueue_is_classic(Q) ->
117117

118118
is_recoverable(Q) when ?is_amqqueue(Q) ->
119119
Node = node(),
120-
Node =:= node(amqqueue:get_pid(Q)) andalso
120+
Node =:= amqqueue:qnode(Q) andalso
121121
%% Terminations on node down will not remove the rabbit_queue
122122
%% record if it is a mirrored queue (such info is now obtained from
123123
%% the policy). Thus, we must check if the local pid is alive

0 commit comments

Comments
 (0)