Details
Description
Messages are not consumed after some point of time in ActiveMQ server.
Facing error like below:
Async error occurred: java.lang.OutOfMemoryError: unable to create new native thread | org.apache.activemq.broker.TransportConnection.Service | ActiveMQ Transport: tcp:///17.98.33.5:60638@61616
java.lang.OutOfMemoryError: unable to create new native thread
at java.lang.Thread.start0(Native Method)
at java.lang.Thread.start(Thread.java:714)
at java.util.concurrent.ThreadPoolExecutor.addWorker(ThreadPoolExecutor.java:950)
at java.util.concurrent.ThreadPoolExecutor.execute(ThreadPoolExecutor.java:1368)
at org.apache.activemq.thread.PooledTaskRunner.wakeup(PooledTaskRunner.java:81)
at org.apache.activemq.broker.region.Queue.asyncWakeup(Queue.java:1719)
at org.apache.activemq.broker.region.Queue.wakeup(Queue.java:1712)
at org.apache.activemq.broker.region.Queue.removeSubscription(Queue.java:582)
at org.apache.activemq.broker.region.AbstractRegion.removeConsumer(AbstractRegion.java:380)
at org.apache.activemq.broker.region.RegionBroker.removeConsumer(RegionBroker.java:364)
at org.apache.activemq.broker.jmx.ManagedRegionBroker.removeConsumer(ManagedRegionBroker.java:247)
at org.apache.activemq.broker.BrokerFilter.removeConsumer(BrokerFilter.java:117)
at org.apache.activemq.advisory.AdvisoryBroker.removeConsumer(AdvisoryBroker.java:253)
at org.apache.activemq.broker.BrokerFilter.removeConsumer(BrokerFilter.java:117)
at org.apache.activemq.broker.BrokerFilter.removeConsumer(BrokerFilter.java:117)
at org.apache.activemq.broker.MutableBrokerFilter.removeConsumer(MutableBrokerFilter.java:123)
at org.apache.activemq.broker.TransportConnection.processRemoveConsumer(TransportConnection.java:651)
at org.apache.activemq.command.RemoveInfo.visit(RemoveInfo.java:76)
at org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:329)
at org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:184)
at org.apache.activemq.transport.MutexTransport.onCommand(MutexTransport.java:50)
at org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:113)
at org.apache.activemq.transport.AbstractInactivityMonitor.onCommand(AbstractInactivityMonitor.java:288)
at org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:83)
at org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:214)
at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:196)
at java.lang.Thread.run(Thread.java:745)