We are using ActiveMQ 5.10 broker with following configuration
JVM heap 48G out of which 70% allocated for memoryUsage
70G storage and 1G for temp
we are using Apache camel 2.10.2 route to consume messages from queue. After
receiving message, we create ~40k smaller messages/ received message and
publish them onto another queue using asyncSend using spring's jmstemplate.
We have configured different connectionFactory for consumer and producer
which work on pooledconnection
As we generate millions of messages onto the queue, we have configured
producerWindowSize on the producerConnectionFactory
Camel Route
<route id="Request-Route" autoStartup="true">
<from uri="jmsQueue:queue:RequestQueue" />
<to uri="bean:service?method=divideAndPublishToQueue"/>
</route>
Problem: After few hours of running we generate ~10 million messages onto
the broker and consumers on the queue starts disappearing. Eventually there
are no consumers and our system comes to halt. The only work around we have
as of now is to restart the application
Question:
1. What will be the behavior of asyncSend producer with producerWindoeSize,
in case broker restarts?
2. We have maxInactiveInterval set to 300000 in the activemq.xml
3. When I inspect the logs I see the consumer starts publishing to the queue
using jmsTemplate and there are no logs which says it finished. There are
several such logs indicating consumer threads most probably in hung state.
--
View this message in context:
http://activemq.2283324.n4.nabble.com/ActiveMQ-consumer-count-is-set-to-0-tp4675930p4702798.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
