Skip to content

Commit c72afe6

Browse files
author
Diana Corbacho
committed
Report reductions and garbage collection options in queue processes
1 parent b9d7e4d commit c72afe6

File tree

1 file changed

+9
-1
lines changed

1 file changed

+9
-1
lines changed

src/rabbit_amqqueue_process.erl

Lines changed: 9 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -116,7 +116,9 @@
116116
slave_pids,
117117
synchronised_slave_pids,
118118
recoverable_slaves,
119-
state
119+
state,
120+
reductions,
121+
garbage_collection
120122
]).
121123

122124
-define(CREATION_EVENT_KEYS,
@@ -925,6 +927,12 @@ i(recoverable_slaves, #q{q = #amqqueue{name = Name,
925927
end;
926928
i(state, #q{status = running}) -> credit_flow:state();
927929
i(state, #q{status = State}) -> State;
930+
i(garbage_collection, _State) ->
931+
{garbage_collection, GC} = erlang:process_info(self(), garbage_collection),
932+
GC;
933+
i(reductions, _State) ->
934+
{reductions, Reductions} = erlang:process_info(self(), reductions),
935+
Reductions;
928936
i(Item, #q{backing_queue_state = BQS, backing_queue = BQ}) ->
929937
BQ:info(Item, BQS).
930938

0 commit comments

Comments
 (0)