diff options
| -rw-r--r-- | src/rabbit_amqqueue.erl | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/rabbit_amqqueue.erl b/src/rabbit_amqqueue.erl index d62e6476..767abeb0 100644 --- a/src/rabbit_amqqueue.erl +++ b/src/rabbit_amqqueue.erl @@ -650,7 +650,7 @@ on_node_down(Node) -> fun () -> QsDels = qlc:e(qlc:q([{QName, delete_queue(QName)} || #amqqueue{name = QName, pid = Pid, - gm_pids = []} + slave_pids = []} <- mnesia:table(rabbit_queue), node(Pid) == Node andalso not rabbit_misc:is_process_alive(Pid)])), |