[rabbitmq-discuss] problem on queue depth checking?

sameekmishra sameek at arosys.com
Wed Mar 14 06:00:22 GMT 2012


I have check that autoack is set false.


Jose Comboni wrote:
> 
> 
> Make sure autoack is set to false.
> 
> From Jose's iPhone
> 
> On Mar 13, 2012, at 6:47 AM, sameekmishra <sameek at arosys.com> wrote:
> 
>> 
>> Defining the channel.basicQos(1) consumer will pick one message and do
>> not
>> pick any message from queue until it not got acknowledgement,if u think
>> that
>> consumer will consume all message from queue that's because I got queue
>> depth zero but This may not be the case as.
>> 
>> What i am thinking is that we need to define channel.basicQos(1) only in
>> the
>> consumer code not in queueDepth because it only give the total count of
>> message.
>> 
>> Even after defining the channel.basicQos(1) on consumer end, I am getting
>> queuedepth value 0,which should be one. may other reason behind that i am
>> getting wrong result.
>> 
>> Thanks
>> Sameek
>> 
>> 
>> Simon MacMullen-2 wrote:
>>> 
>>> On 13/03/12 13:01, sameekmishra wrote:
>>>> Now if i publish 2 messages then one message will be consumed(and
>>>> thread
>>>> will sleep for one minute) and one will be in the queue;
>>>> And queue depth checking thread must show the queuedepth = 1. But I am
>>>> getting the queuedepth 0.
>>>> But if we dont consume the message from queue then queuedepth is shown
>>>> correctly.
>>> 
>>> RabbitMQ will by default push as many messages to the consumer as it 
>>> can. On the consumer side they end up buffered in the QueueingConsumer.
>>> 
>>> To change this behaviour, invoke channel.basicQos() and use acks. This 
>>> will bound the number of unacknowledged messages RabbitMQ will push to 
>>> your consumer.
>>> 
>>> Cheers, Simon
>>> 
>>> -- 
>>> Simon MacMullen
>>> RabbitMQ, VMware
>>> _______________________________________________
>>> rabbitmq-discuss mailing list
>>> rabbitmq-discuss at lists.rabbitmq.com
>>> https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss
>>> 
>>> 
>> -- 
>> View this message in context:
>> http://old.nabble.com/problem-on-queue-depth-checking--tp33494003p33494378.html
>> Sent from the RabbitMQ mailing list archive at Nabble.com.
>> 
>> _______________________________________________
>> 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
> 
> 
-- 
View this message in context: http://old.nabble.com/problem-on-queue-depth-checking--tp33494003p33499621.html
Sent from the RabbitMQ mailing list archive at Nabble.com.



More information about the rabbitmq-discuss mailing list