[rabbitmq-discuss] How check for existing queue consumer

[cw storm]

Hi Simon and team,

Besides the number of active queue consumer, can I get the actual name or
value that's in the consumer tag?


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

> 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/49c1b8ef/attachment.html>