Consuming all messages from a queue

[garfen <ga...@hotmail.com>]

Hello,

I'm using ActiveMQ 5.5.1 with ActiveMQ-CPP.

I've pre-loaded a queue with 30 000 messages and have a single consumer
(INDIVIDUAL_ACKNOWLEDGE) that sits in a tight loop receiving messages from
the queue using aConsumer->receive(1000).

I was hoping of being able to consume all the messages from the queue in a
somewhat continuous manner. Instead I may get 200 messages initially,
followed by ~30 sec. of no messages. Then 4000 messages, followed by ~30
sec. of no messages. Another 4000 messages, waiting for ~30 sec., and so on.

Running the test once more will consume the message continuously.
Re-starting the AMQ broker, and I'm back in the situation explained above.

I've tried both 0 and 30000 for the prefetch limit in the connection uri
without luck
(tcp://my.host:61616?jms.prefetchPolicy.all=30000&wireFormat=openwire).

In the end I would like to have several consumers consuming messages from
the queue. Each message would represent a job to process, which could take
several hours to complete and all the consumers would together hold, say 500
000, such jobs. Now, if some consumer goes down, it is important that the
jobs will be distributed and continued as soon as possible by other
consumers.

It would be much appreciated if someone could give me some hints regarding
this.

Thanks in advance.




--
View this message in context: http://activemq.2283324.n4.nabble.com/Consuming-all-messages-from-a-queue-tp4660812.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.