Thanks a lot for your reply Tim, Below is the metrics details i grabbed from the server. ActiveMQ: 5.15.0 non-persistent Running consumer -> singleton -> onMessage() -> submit callables -> callables send updated message to destination messages -> 600/hour messages size -> 8 byte messages consume interval -> listener pools continuously as soon as the message arrives JVM: -Xms1g -Xmx3g Application: -Xms4g -Xmx4g GCTYPE: ParallelGC
Its only consumer gives issues in Broker service side. 1. Yes. i do have to see how to enable PFC. But just a thought since its only a consumer application do we need to to enable PFC? if so how do i enable for consumer client side using programming? 2. Also seeing below warning and does that makes sense even if am using non persistence messages? WARN BrokerService:2139 - Temporary Store limit is 51200 mb (current store usage is 0 mb). The data directory: /temp only has 2000 mb of usable space. - resetting to maximum available disk space: 2000 mb 3. The consumer design is like below, am i doing something wrong in the design? Consumer Main -> inject Consumer (init->activeMQ producer:consumer, onMessage->call workerThread(consumer) ) -> workerThread (send message to consumer, producer) Expecting your valuable comments on this. -- Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html