diff options
| author | Michael Klishin <michael@novemberain.com> | 2016-06-29 19:13:55 +0300 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2016-06-29 19:13:55 +0300 |
| commit | c0bd3bac9ec8ed7d6dd64c8039bf33758add92cf (patch) | |
| tree | 581c04bbb32fafa4ce4fa83229dc679266c3fbcb /src | |
| parent | 0923c9676fa7a1e5a839551ed6a11bb8192ff2c6 (diff) | |
| parent | c72afe6bc1794ef85515743bf53400c6ea4e6dfb (diff) | |
| download | rabbitmq-server-git-c0bd3bac9ec8ed7d6dd64c8039bf33758add92cf.tar.gz | |
Merge pull request #858 from rabbitmq/rabbitmq-management-211
Report queue reductions per second and GC options
Diffstat (limited to 'src')
| -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). |