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 | d041c6a3c7d9420f197bd30bccbfdd263f812f5c (patch) | |
| tree | d50ddf29be584472669b44b036c966bd2847ec3c | |
| parent | 1acaaffbbb9b8749b180a6f0b10b74cf6c252cba (diff) | |
| parent | 17e49f71fa1411d352845a0bdbceb31017ec3232 (diff) | |
| download | rabbitmq-server-d041c6a3c7d9420f197bd30bccbfdd263f812f5c.tar.gz | |
Merged bug25193
| -rw-r--r-- | docs/rabbitmqctl.1.xml | 21 | ||||
| -rw-r--r-- | src/rabbit_amqqueue_process.erl | 3 |
2 files changed, 24 insertions, 0 deletions
diff --git a/docs/rabbitmqctl.1.xml b/docs/rabbitmqctl.1.xml index 11d85e9e..73347cea 100644 --- a/docs/rabbitmqctl.1.xml +++ b/docs/rabbitmqctl.1.xml @@ -986,6 +986,27 @@ <listitem><para>Number of consumers.</para></listitem> </varlistentry> <varlistentry> + <term>active_consumers</term> + <listitem> + <para> + Number of active consumers. An active consumer is + one which could immediately receive any messages + sent to the queue - i.e. it is not limited by its + prefetch count, TCP congestion, flow control, or + because it has issued channel.flow. At least one + of messages_ready and active_consumers must always + be zero. + </para> + <para> + Note that this value is an instantaneous snapshot + - when consumers are restricted by their prefetch + count they may only appear to be active for small + fractions of a second until more messages are sent + out. + </para> + </listitem> + </varlistentry> + <varlistentry> <term>memory</term> <listitem><para>Bytes of memory consumed by the Erlang process associated with the queue, including stack, heap and internal structures.</para></listitem> diff --git a/src/rabbit_amqqueue_process.erl b/src/rabbit_amqqueue_process.erl index dfd0ab7e..e68d691e 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; |