activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From IBeaumont <>
Subject Q Consumers stop receiving messages
Date Tue, 13 Jan 2009 15:38:16 GMT

I've got a fairly complex app, that takes msgs, processing them and sticks
them on the same or different queues.

The queues are pre-loaded with persistent messages before the application
starts (50000).  Once it starts processing things work fine for a while and
then the consumers stop receiving any messages.  I have a 4 consumers for
each queue, and there are 3 different queues.

Looking at jconsole all consumes are waiting here:

State: WAITING on java.lang.Object@1801d4a
Total blocked: 20  Total waited: 158

Stack trace: 
java.lang.Object.wait(Native Method)

If I look at the broker (and I'm not really sure what to look at here), the
thread for my queue that should be dispatching messages looks like this 
Name: QueueThread:queue://csPIQ
State: WAITING on
Total blocked: 2,365  Total waited: 6,717

Stack trace: 
sun.misc.Unsafe.park(Native Method)
java.util.concurrent.locks.LockSupport.park(Unknown Source)
java.util.concurrent.LinkedBlockingQueue.take(Unknown Source)
java.util.concurrent.ThreadPoolExecutor.getTask(Unknown Source)
java.util.concurrent.ThreadPoolExecutor$ Source) Source)

The broker is configured with producerFlowControl="false", using TCP, a
pre-fetch size of 0 and I've also set sendFailIfNoSpace="true".

Any ideas on what my problem is or how/where I look in ActiveMQ to find the
cause, or if the problem is with the consumer.


View this message in context:
Sent from the ActiveMQ - User mailing list archive at

View raw message