diff options
| author | Michael Klishin <michael@clojurewerkz.org> | 2016-06-29 19:17:11 +0300 |
|---|---|---|
| committer | Michael Klishin <michael@clojurewerkz.org> | 2016-06-29 19:17:11 +0300 |
| commit | f67a8477dee59e79a66c9ed464f04af6d559e811 (patch) | |
| tree | 1bbe0e505fc57635464ce4a8739119986ba05912 | |
| parent | f0f43f8002678451bdb1e1d7ccdd5e7723949625 (diff) | |
| parent | c0bd3bac9ec8ed7d6dd64c8039bf33758add92cf (diff) | |
| download | rabbitmq-server-git-f67a8477dee59e79a66c9ed464f04af6d559e811.tar.gz | |
Merge branch 'stable'
| -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 b695600cfd..10fcfe7493 100644 --- a/src/rabbit_amqqueue_process.erl +++ b/src/rabbit_amqqueue_process.erl @@ -118,7 +118,9 @@ slave_pids, synchronised_slave_pids, recoverable_slaves, - state + state, + reductions, + garbage_collection ]). -define(CREATION_EVENT_KEYS, @@ -934,6 +936,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). |