diff options
| author | Emile Joubert <emile@rabbitmq.com> | 2013-06-21 15:00:42 +0100 |
|---|---|---|
| committer | Emile Joubert <emile@rabbitmq.com> | 2013-06-21 15:00:42 +0100 |
| commit | 485016c3457a0fe24e89f45ccd6de22f263a0253 (patch) | |
| tree | c67f8bd5d533f3aee970ffe479714ea555b92aac /src | |
| parent | 75c1a0d61894626a6446aded6218a079d4d986b6 (diff) | |
| parent | e1509dec5b847feb273e97d9fea7ebb454484bc3 (diff) | |
| download | rabbitmq-server-git-485016c3457a0fe24e89f45ccd6de22f263a0253.tar.gz | |
Merged stable into default
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_amqqueue.erl | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/src/rabbit_amqqueue.erl b/src/rabbit_amqqueue.erl index e0fbaf77df..74fd70ae68 100644 --- a/src/rabbit_amqqueue.erl +++ b/src/rabbit_amqqueue.erl @@ -219,8 +219,10 @@ find_durable_queues() -> %% TODO: use dirty ops instead rabbit_misc:execute_mnesia_transaction( fun () -> - qlc:e(qlc:q([Q || Q = #amqqueue{pid = Pid} + qlc:e(qlc:q([Q || Q = #amqqueue{name = Name, + pid = Pid} <- mnesia:table(rabbit_durable_queue), + mnesia:read(rabbit_queue, Name, read) =:= [], node(Pid) == Node])) end). |