diff options
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_amqqueue.erl | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/src/rabbit_amqqueue.erl b/src/rabbit_amqqueue.erl index e322e844e1..f525ffd1ad 100644 --- a/src/rabbit_amqqueue.erl +++ b/src/rabbit_amqqueue.erl @@ -492,9 +492,11 @@ on_node_down(Node) -> rabbit_binding:new_deletions(), rabbit_misc:execute_mnesia_transaction( fun () -> qlc:e(qlc:q([delete_queue(QueueName) || - #amqqueue{name = QueueName, pid = Pid} + #amqqueue{name = QueueName, pid = Pid, + extra_pids = EPids} <- mnesia:table(rabbit_queue), - node(Pid) == Node])) + node(Pid) == Node, + [] =:= EPids])) end))). delete_queue(QueueName) -> |