diff options
| author | Emile Joubert <emile@rabbitmq.com> | 2012-10-03 12:00:53 +0100 |
|---|---|---|
| committer | Emile Joubert <emile@rabbitmq.com> | 2012-10-03 12:00:53 +0100 |
| commit | 06d8fc293c2061b1c3ee995239242823f2d2b795 (patch) | |
| tree | d50ddf29be584472669b44b036c966bd2847ec3c /src | |
| parent | bb87426c775813281470c2841c781efdd203db2c (diff) | |
| parent | afeeb9e94bcef3bd591d6715818017a88486d44d (diff) | |
| download | rabbitmq-server-git-06d8fc293c2061b1c3ee995239242823f2d2b795.tar.gz | |
Merged bug25193
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_amqqueue_process.erl | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/src/rabbit_amqqueue_process.erl b/src/rabbit_amqqueue_process.erl index dfd0ab7e19..e68d691e3f 100644 --- a/src/rabbit_amqqueue_process.erl +++ b/src/rabbit_amqqueue_process.erl @@ -92,6 +92,7 @@ messages_unacknowledged, messages, consumers, + active_consumers, memory, slave_pids, synchronised_slave_pids, @@ -910,6 +911,8 @@ i(messages, State) -> messages_unacknowledged]]); i(consumers, _) -> consumer_count(); +i(active_consumers, _) -> + active_consumer_count(); i(memory, _) -> {memory, M} = process_info(self(), memory), M; |