[rabbitmq-discuss] How check for existing queue consumer

Wed Feb 12 15:48:26 GMT 2014

Thanks guys.  The "int consumers =
channel.queueDeclarePassive(strQueueName).getConsumerCount();" will meet my
requirement.  In my service, I will check to see if that number is greater
than 0 or not.  If not, then issue "basicConsume".  But if my other server
need to also register the queue consumer as well, then maybe I need to
check if the number equals 2 instead.

I'm just wondering if you have two servers, do you have both of your server
create a queue consumer to the queue?

On Wed, Feb 12, 2014 at 10:14 AM, cw storm <cwstorm at gmail.com> wrote:

> Thanks guys.
>
> If I declare the queue exclusive, then my other server won't be able to
> register the queue consumer right?  We have two ESB servers for load
> balancing.  That means, two queue consumer for that queue.  However, if
> someone accidentally execute the service, then it'll create a new
> channel/connection and queue consumer for that queue.  That I don't want to
> happen.
>
>
> On Wed, Feb 12, 2014 at 10:04 AM, Alvaro Videla <videlalvaro at gmail.com>wrote:
>
>> Hi,
>>
>> If you need to have just one consumer per queue, then declare the
>> queue as exclusive.
>>
>> If you want to check if there are consumers attached to a particular
>> queue, then inspect the return values of issuing a passive
>> queueDeclare.
>>
>> Regards,
>>
>> Alvaro
>>
>> On Wed, Feb 12, 2014 at 3:59 PM, cw storm <cwstorm at gmail.com> wrote:
>> > Hi,
>> >
>> > I have a situation where someone executed the service that calls the
>> > "basicConsume" which basically assigns a queue consumer to that queue
>> on a
>> > different channel.  This cause multiple queue consumer for that queue.
>>  Is
>> > there someway in that service where I can check to see if an existing
>> queue
>> > consumer already exist for that queue before issue'ing the
>> "basicConsume"?
>> >
>> > _______________________________________________
>> > rabbitmq-discuss mailing list
>> > rabbitmq-discuss at lists.rabbitmq.com
>> > https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss
>> >
>> _______________________________________________
>> rabbitmq-discuss mailing list
>> rabbitmq-discuss at lists.rabbitmq.com
>> https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss
>>
>
>
-------------- next part --------------
An HTML attachment was scrubbed...
URL: <http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/attachments/20140212/d53faa80/attachment.html>