From 2f0729042ad6f7adf81ea509809c29f9bb24c8f6 Mon Sep 17 00:00:00 2001
From: Simon MacMullen <simon@rabbitmq.com>
Date: Fri, 28 Sep 2012 15:21:42 +0100
Subject: active_consumers info item.

---
 docs/rabbitmqctl.1.xml          | 8 ++++++++
 src/rabbit_amqqueue_process.erl | 3 +++
 2 files changed, 11 insertions(+)

diff --git a/docs/rabbitmqctl.1.xml b/docs/rabbitmqctl.1.xml
index 11d85e9e..6c4ee7d5 100644
--- a/docs/rabbitmqctl.1.xml
+++ b/docs/rabbitmqctl.1.xml
@@ -985,6 +985,14 @@
                 <term>consumers</term>
                 <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. At least one of
+                messages_ready and active_consumers must always be
+                zero.</para></listitem>
+              </varlistentry>
               <varlistentry>
                 <term>memory</term>
                 <listitem><para>Bytes of memory consumed by the Erlang process associated with the
diff --git a/src/rabbit_amqqueue_process.erl b/src/rabbit_amqqueue_process.erl
index 10ac5bea..55bd970c 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,
@@ -914,6 +915,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;
-- 
cgit v1.2.1