Skip to content

Commit 0c30c18

Browse files
committed
Correctly check for exclusive queue
1 parent 793b1af commit 0c30c18

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

src/rabbit_amqqueue.erl

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -922,8 +922,8 @@ is_mirrored(Q) ->
922922

923923
is_exclusive(#amqqueue{exclusive_owner = none}) ->
924924
false;
925-
is_exclusive(#amqqueue{exclusive_owner = Pid}) ->
926-
rabbit_mnesia:is_process_alive(Pid).
925+
is_exclusive(#amqqueue{exclusive_owner = Pid}) when is_pid(Pid) ->
926+
true.
927927

928928
on_node_up(Node) ->
929929
ok = rabbit_misc:execute_mnesia_transaction(

0 commit comments

Comments
 (0)