diff options
| -rw-r--r-- | src/rabbit_amqqueue_process.erl | 10 |
1 files changed, 9 insertions, 1 deletions
diff --git a/src/rabbit_amqqueue_process.erl b/src/rabbit_amqqueue_process.erl index d3cc94bb0e..0eb8dce1dd 100644 --- a/src/rabbit_amqqueue_process.erl +++ b/src/rabbit_amqqueue_process.erl @@ -113,7 +113,9 @@ slave_pids, synchronised_slave_pids, recoverable_slaves, - state + state, + reductions, + garbage_collection ]). -define(CREATION_EVENT_KEYS, @@ -922,6 +924,12 @@ i(recoverable_slaves, #q{q = #amqqueue{name = Name, end; i(state, #q{status = running}) -> credit_flow:state(); i(state, #q{status = State}) -> State; +i(garbage_collection, _State) -> + {garbage_collection, GC} = erlang:process_info(self(), garbage_collection), + GC; +i(reductions, _State) -> + {reductions, Reductions} = erlang:process_info(self(), reductions), + Reductions; i(Item, #q{backing_queue_state = BQS, backing_queue = BQ}) -> BQ:info(Item, BQS). |