@@ -365,7 +365,10 @@ action(status, Node, [], _Opts, Inform) ->
365
365
366
366
action (cluster_status , Node , [], _Opts , Inform ) ->
367
367
Inform (" Cluster status of node ~p " , [Node ]),
368
- display_call_result (Node , {rabbit_mnesia , status , []});
368
+ Status = unsafe_rpc (Node , rabbit_mnesia , status , []),
369
+ io :format (" ~p~n " , [Status ++ [{alarms ,
370
+ [alarms_by_node (Name ) || Name <- nodes_in_cluster (Node )]}]]),
371
+ ok ;
369
372
370
373
action (environment , Node , _App , _Opts , Inform ) ->
371
374
Inform (" Application environment of node ~p " , [Node ]),
@@ -878,3 +881,11 @@ prettify_typed_amqp_value(_Type, Value) -> Value.
878
881
split_list ([]) -> [];
879
882
split_list ([_ ]) -> exit (even_list_needed );
880
883
split_list ([A , B | T ]) -> [{A , B } | split_list (T )].
884
+
885
+ nodes_in_cluster (Node ) ->
886
+ unsafe_rpc (Node , rabbit_mnesia , cluster_nodes , [running ]).
887
+
888
+ alarms_by_node (Name ) ->
889
+ Status = unsafe_rpc (Name , rabbit , status , []),
890
+ {_ , As } = lists :keyfind (alarms , 1 , Status ),
891
+ {Name , As }.
0 commit comments