diff options
| author | Diana Corbacho <diana@rabbitmq.com> | 2017-08-07 15:06:55 +0200 |
|---|---|---|
| committer | Diana Corbacho <diana@rabbitmq.com> | 2017-08-07 15:07:12 +0200 |
| commit | e7a67da88293ebe5d8baf2f73eeb04d7d235a2dc (patch) | |
| tree | ef7f6e51b3432f58fa25db4cefc5f7418ff94204 | |
| parent | 75228f4e000c9a0087f103b2e1e91e3b4b5b0a10 (diff) | |
| download | rabbitmq-server-git-e7a67da88293ebe5d8baf2f73eeb04d7d235a2dc.tar.gz | |
Use info items to list unresponsive queues
rabbitmq-cli#207
[#149059849]
| -rw-r--r-- | src/rabbit_amqqueue.erl | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/src/rabbit_amqqueue.erl b/src/rabbit_amqqueue.erl index 122ba3e4ba..f76566ffb9 100644 --- a/src/rabbit_amqqueue.erl +++ b/src/rabbit_amqqueue.erl @@ -38,7 +38,7 @@ -export([on_node_up/1, on_node_down/1]). -export([update/2, store_queue/1, update_decorators/1, policy_changed/2]). -export([update_mirroring/1, sync_mirrors/1, cancel_sync_mirrors/1, is_mirrored/1]). --export([emit_unresponsive/5, emit_unresponsive_local/4, is_unresponsive/2]). +-export([emit_unresponsive/6, emit_unresponsive_local/5, is_unresponsive/2]). -export([pid_of/1, pid_of/2]). @@ -705,18 +705,18 @@ emit_info_down(VHostPath, Items, Ref, AggregatorPid) -> AggregatorPid, Ref, fun(Q) -> info_down(Q, Items, down) end, list_down(VHostPath)). -emit_unresponsive_local(VHostPath, Timeout, Ref, AggregatorPid) -> +emit_unresponsive_local(VHostPath, Items, Timeout, Ref, AggregatorPid) -> rabbit_control_misc:emitting_map_with_exit_handler( AggregatorPid, Ref, fun(Q) -> case is_unresponsive(Q, Timeout) of - true -> [{name, Q#amqqueue.name}]; + true -> info_down(Q, Items, unresponsive); false -> [] end end, list_local(VHostPath) ). -emit_unresponsive(Nodes, VHostPath, Timeout, Ref, AggregatorPid) -> +emit_unresponsive(Nodes, VHostPath, Items, Timeout, Ref, AggregatorPid) -> Pids = [ spawn_link(Node, rabbit_amqqueue, emit_unresponsive_local, - [VHostPath, Timeout, Ref, AggregatorPid]) || Node <- Nodes ], + [VHostPath, Items, Timeout, Ref, AggregatorPid]) || Node <- Nodes ], rabbit_control_misc:await_emitters_termination(Pids). info_local(VHostPath) -> |