diff options
| author | Matthew Sackman <matthew@rabbitmq.com> | 2010-12-14 17:52:13 +0000 |
|---|---|---|
| committer | Matthew Sackman <matthew@rabbitmq.com> | 2010-12-14 17:52:13 +0000 |
| commit | c2c9a6526e9caec9be22b5e1531c640631369ea0 (patch) | |
| tree | b1fd96bb7815ffa33bd9dfcd72aaee47078e5980 | |
| parent | 817aa2674974ea425b64cc34a520dae112819538 (diff) | |
| download | rabbitmq-server-git-c2c9a6526e9caec9be22b5e1531c640631369ea0.tar.gz | |
inline
| -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) -> |