diff options
| -rw-r--r-- | src/rabbit_amqqueue.erl | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/rabbit_amqqueue.erl b/src/rabbit_amqqueue.erl index 9210e81b95..8b1159e8db 100644 --- a/src/rabbit_amqqueue.erl +++ b/src/rabbit_amqqueue.erl @@ -922,8 +922,8 @@ is_mirrored(Q) -> is_exclusive(#amqqueue{exclusive_owner = none}) -> false; -is_exclusive(#amqqueue{exclusive_owner = Pid}) -> - rabbit_mnesia:is_process_alive(Pid). +is_exclusive(#amqqueue{exclusive_owner = Pid}) when is_pid(Pid) -> + true. on_node_up(Node) -> ok = rabbit_misc:execute_mnesia_transaction( |