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 | 8829856cbf65acfdfb43f64a75ee3647f459b5c3 (patch) | |
| tree | f5f010d8f35e8753d2a47e57b1d1549156b3c583 /src | |
| parent | 9fcbb9b80dffb6ea979e16563e1a8ea56232ab45 (diff) | |
| download | rabbitmq-server-git-8829856cbf65acfdfb43f64a75ee3647f459b5c3.tar.gz | |
Umm, be less than 100% wrong.
Diffstat (limited to 'src')
| -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 84b6f35a88..74fd70ae68 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). |