diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2013-06-20 15:25:25 +0100 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2013-06-20 15:25:25 +0100 |
| commit | b72670200638d5848aad710bcf3396eeee9c7fc0 (patch) | |
| tree | f5f010d8f35e8753d2a47e57b1d1549156b3c583 | |
| parent | 92edfb501c0bd34f58e6ce9a8a4f7c9d13ddacd7 (diff) | |
| download | rabbitmq-server-bug25615.tar.gz | |
Umm, be less than 100% wrong.bug25615
| -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). |