diff options
| -rw-r--r-- | src/rabbit_amqqueue.erl | 5 |
1 files changed, 2 insertions, 3 deletions
diff --git a/src/rabbit_amqqueue.erl b/src/rabbit_amqqueue.erl index 1e83265f76..e4bc9f764f 100644 --- a/src/rabbit_amqqueue.erl +++ b/src/rabbit_amqqueue.erl @@ -488,10 +488,9 @@ on_node_down(Node) -> rabbit_misc:execute_mnesia_transaction( fun () -> qlc:e(qlc:q([delete_queue(QueueName) || #amqqueue{name = QueueName, pid = Pid, - extra_pids = EPids} + extra_pids = []} <- mnesia:table(rabbit_queue), - node(Pid) == Node, - [] =:= EPids])) + node(Pid) == Node])) end))). delete_queue(QueueName) -> |