diff options
| author | Emile Joubert <emile@rabbitmq.com> | 2013-07-19 13:50:17 +0100 |
|---|---|---|
| committer | Emile Joubert <emile@rabbitmq.com> | 2013-07-19 13:50:17 +0100 |
| commit | 21ca74af618e17eb9663d9b83d0f99f689e448de (patch) | |
| tree | 8af4e2a3035bbd0e3b0d6a57e067fc67f873828a /src | |
| parent | 61e69ebee4861b7fa87344f5b0f010ecb6f62593 (diff) | |
| download | rabbitmq-server-git-21ca74af618e17eb9663d9b83d0f99f689e448de.tar.gz | |
Checking gm_pids is a better way of filtering out HA queues
Diffstat (limited to 'src')
| -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 767abeb03d..d62e647613 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, - slave_pids = []} + gm_pids = []} <- mnesia:table(rabbit_queue), node(Pid) == Node andalso not rabbit_misc:is_process_alive(Pid)])), |