Mailing-List: contact users-help@activemq.apache.org; run by ezmlm
Precedence: bulk
Reply-To: users@activemq.apache.org
Subject: Re: How to find consumers on an exiting ActiveMQ Queue in c#
To: users@activemq.apache.org
References: <1501076329830-4728927.post@n4.nabble.com>
 <6de607c8-df38-0693-e341-021bd1b1357d@gmail.com>
 <1501084582655-4728935.post@n4.nabble.com>
 <1501084871370-4728936.post@n4.nabble.com>
From: Timothy Bish <tabish121@gmail.com>
Message-ID: <f8a52bad-996b-780a-eaf8-b347aff2597b@gmail.com>
Date: Wed, 26 Jul 2017 12:05:39 -0400
User-Agent: Mozilla/5.0 (X11; Linux x86_64; rv:52.0) Gecko/20100101
 Thunderbird/52.2.1
MIME-Version: 1.0
In-Reply-To: <1501084871370-4728936.post@n4.nabble.com>
Content-Type: text/plain; charset=utf-8; format=flowed
Content-Transfer-Encoding: 7bit
Content-Language: en-US
archived-at: Wed, 26 Jul 2017 16:05:47 -0000

On 07/26/2017 12:01 PM, zaeem wrote:
> Below snippets lets you list Queues on the broker,Topics but i need
> something similar to list consumers on Queues for that broker by just
> passing a Queue Name.

No such API exists outside JMX, you have to do the work using only 
advisories and statistics

>
>          public const string QUEUE_ADVISORY_DESTINATION =
> "ActiveMQ.Advisory.Queue";
>          public const string TOPIC_ADVISORY_DESTINATION =
> "ActiveMQ.Advisory.Topic";
>          public const string TEMPQUEUE_ADVISORY_DESTINATION =
> "ActiveMQ.Advisory.TempQueue";
>          public const string TEMPTOPIC_ADVISORY_DESTINATION =
> "ActiveMQ.Advisory.TempTopic";
>
>   private static void Enumerate(string destination, Action<DestinationInfo>
> action)
>          {
>              IDestination dest = _session.GetTopic(destination);
>              using (IMessageConsumer consumer =
> _session.CreateConsumer(dest))
>              {
>                  IMessage advisory;
>
>                  while ((advisory =
> consumer.Receive(TimeSpan.FromMinutes(2000))) != null)
>                  {
>                      ActiveMQMessage am = advisory as ActiveMQMessage;
>                      if (am != null & am.DataStructure != null)
>                      {
>                          DestinationInfo info = am.DataStructure as
> DestinationInfo;
>                          if (info != null)
>                          {
>                              action(info);
>                          }
>                      }
>                  }
>              }
>          }
>
>        
>
>          public static void EnumerateQueues()
>          {
>              Console.WriteLine("Listing all Queues on Broker:");
>              Enumerate(QUEUE_ADVISORY_DESTINATION, info =>
>                  Console.WriteLine("   Queue: " + info.Destination));
>              Console.WriteLine("Listing Complete.");
>          }
>
>          public static void EnumerateTopics()
>          {
>              Console.WriteLine("Listing all Topics on Broker:");
>              Enumerate(TOPIC_ADVISORY_DESTINATION, info =>
>                  Console.WriteLine("   Topic: " + info.Destination));
>              Console.WriteLine("Listing Complete.");
>
>          }
>
>          public static void EnumerateDestinations()
>          {
>              Console.WriteLine("Listing all Destinations on Broker:");
>              Enumerate(ALLDEST_ADVISORY_DESTINATION, info =>
>              {
>                  string destType = info.Destination.IsTopic ? "Topic" :
> "Qeue";
>                  destType = info.Destination.IsTemporary ? "Temporary" +
> destType : destType;
>                  Console.WriteLine("   " + destType + ": " +
> info.Destination);
>              });
>              Console.WriteLine("Listing Complete.");
>          }
>
>
>
> --
> View this message in context: http://activemq.2283324.n4.nabble.com/How-to-find-consumers-on-an-existing-ActiveMQ-Queue-in-c-tp4728927p4728936.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>

-- 
Tim Bish
twitter: @tabish121
blog: http://timbish.blogspot.com/