[rabbitmq-discuss] checking no of message in queue
cheepu
shammi at arosys.com
Tue Mar 22 09:01:50 GMT 2011
Hi
I am checking the number of message in the queue.
I am using the fillowing code for this.
channel.exchangeDeclare("exchange", "direct",true);
queuemessageSize=channel.queueDeclarePassive("queue").getMessageCount();
I am using the same connection object. but the channel for both task is
different.
I started two thread( consumer thread to consume msg from queue and a thread
to check no of message in queue) which are running continuously but I can
pause and stop the consumer thread.
I did the following steps:
1. Produced 20 message
Result: queue depth is 0 because all the messages are consumed by the
consumer thread
This is expected result.
2. Next I paused the consumer thread. and then again produced 20 message.
Result: queue depth is 0( This is unexpected because there are 20 messages
in queue) and message is not consumed by the consumer thread( because they
are paused ).
3. Next I stopped the consumer:
Result: Now I am getting the no of message in the queue ie 20.
Question:
Why when the consumer is sleeping then my queue size ( ie message in queue)
is zero?
I want the queue size at the time when the consumer in the paused state.
What wrong I am doing and what should I do?
Thanks
--
View this message in context: http://old.nabble.com/checking-no-of-message-in-queue-tp31208079p31208079.html
Sent from the RabbitMQ mailing list archive at Nabble.com.
More information about the rabbitmq-discuss
mailing list