diff options
author | Simon MacMullen <simon@rabbitmq.com> | 2014-06-19 16:57:15 +0100 |
---|---|---|
committer | Simon MacMullen <simon@rabbitmq.com> | 2014-06-19 16:57:15 +0100 |
commit | 9688d8bb3fbe59f18eacc3c923d47bec1b47af3a (patch) | |
tree | 346e384037b27d13f478233333d2ae763c2a3498 /src/rabbit_amqqueue_process.erl | |
parent | b4d3a4b4dc7b71210674390be185e3ae1b21bb3a (diff) | |
download | rabbitmq-server-9688d8bb3fbe59f18eacc3c923d47bec1b47af3a.tar.gz |
Maintain down_slave_nodes so we might have a clue where to look to recover from.
Diffstat (limited to 'src/rabbit_amqqueue_process.erl')
-rw-r--r-- | src/rabbit_amqqueue_process.erl | 9 |
1 files changed, 9 insertions, 0 deletions
diff --git a/src/rabbit_amqqueue_process.erl b/src/rabbit_amqqueue_process.erl index 97206df3..4082c53d 100644 --- a/src/rabbit_amqqueue_process.erl +++ b/src/rabbit_amqqueue_process.erl @@ -84,6 +84,7 @@ memory, slave_pids, synchronised_slave_pids, + down_slave_nodes, backing_queue_status, state ]). @@ -810,6 +811,14 @@ i(synchronised_slave_pids, #q{q = #amqqueue{name = Name}}) -> false -> ''; true -> SSPids end; +i(down_slave_nodes, #q{q = #amqqueue{name = Name, + durable = Durable}}) -> + {ok, Q = #amqqueue{down_slave_nodes = Nodes}} = + rabbit_amqqueue:lookup(Name), + case Durable andalso rabbit_mirror_queue_misc:is_mirrored(Q) of + false -> ''; + true -> Nodes + end; i(state, #q{status = running}) -> credit_flow:state(); i(state, #q{status = State}) -> State; i(backing_queue_status, #q{backing_queue_state = BQS, backing_queue = BQ}) -> |