diff options
| -rw-r--r-- | src/rabbit_amqqueue.erl | 4 |
1 files changed, 1 insertions, 3 deletions
diff --git a/src/rabbit_amqqueue.erl b/src/rabbit_amqqueue.erl index 84b6f35a..74fd70ae 100644 --- a/src/rabbit_amqqueue.erl +++ b/src/rabbit_amqqueue.erl @@ -222,9 +222,7 @@ find_durable_queues() -> qlc:e(qlc:q([Q || Q = #amqqueue{name = Name, pid = Pid} <- mnesia:table(rabbit_durable_queue), - #amqqueue{name = Name2} - <- mnesia:table(rabbit_queue), - Name =:= Name2, + mnesia:read(rabbit_queue, Name, read) =:= [], node(Pid) == Node])) end). |