diff options
| author | Luke Bakken <lbakken@pivotal.io> | 2017-08-08 08:36:53 -0700 |
|---|---|---|
| committer | Luke Bakken <lbakken@pivotal.io> | 2017-08-08 08:36:53 -0700 |
| commit | 0c30c18031a20eff72fc85bddb41d5545eda925f (patch) | |
| tree | 8ba4725cd427463e3a35bad90195e15cf81174cc | |
| parent | 793b1af1902450feb462f9cf44c98e01ed9eedbf (diff) | |
| download | rabbitmq-server-git-0c30c18031a20eff72fc85bddb41d5545eda925f.tar.gz | |
Correctly check for exclusive queue
| -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( |