Skip to content

Commit 41ce0f9

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

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
@@ -123,7 +123,7 @@ delete(Q, IfUnused, IfEmpty, ActingUser) when ?amqqueue_is_classic(Q) ->
123123

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

0 commit comments

Comments
 (0)