On the Client "ActiveMQ Transport: tcp://perf4bc3b/170.137.233.156:5112" prio=3 tid=0x00000000075b3800 nid=0x1227f runnable [0xfffffd7e68fca000] java.lang.Thread.State: RUNNABLE at java.net.SocketOutputStream.socketWrite0(Native Method) at java.net.SocketOutputStream.socketWrite(SocketOutputStream.java:92) at java.net.SocketOutputStream.write(SocketOutputStream.java:136) at org.apache.activemq.transport.tcp.TcpBufferedOutputStream.flush(TcpBufferedOutputStream.java:115) at java.io.DataOutputStream.flush(DataOutputStream.java:106) at org.apache.activemq.transport.tcp.TcpTransport.oneway(TcpTransport.java:182) at org.apache.activemq.transport.InactivityMonitor.oneway(InactivityMonitor.java:255) - locked <0xfffffd7eb605c250> (a java.util.concurrent.atomic.AtomicBoolean) at org.apache.activemq.transport.TransportFilter.oneway(TransportFilter.java:85) at org.apache.activemq.transport.WireFormatNegotiator.oneway(WireFormatNegotiator.java:104) at org.apache.activemq.transport.failover.FailoverTransport.oneway(FailoverTransport.java:550) - locked <0xfffffd7e8fb1a948> (a java.lang.Object) at org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.java:40) - locked <0xfffffd7e8fb1ba10> (a java.lang.Object) at org.apache.activemq.transport.ResponseCorrelator.oneway(ResponseCorrelator.java:60) at org.apache.activemq.ActiveMQConnection.doAsyncSendPacket(ActiveMQConnection.java:1257) at org.apache.activemq.ActiveMQConnection.asyncSendPacket(ActiveMQConnection.java:1251) at org.apache.activemq.ActiveMQSession.asyncSendPacket(ActiveMQSession.java:1863) at org.apache.activemq.ActiveMQSession.sendAck(ActiveMQSession.java:2029) at org.apache.activemq.ActiveMQSession.sendAck(ActiveMQSession.java:2024) at org.apache.activemq.ActiveMQMessageConsumer.afterMessageIsConsumed(ActiveMQMessageConsumer.java:871) - locked <0xfffffd7e8fc5bf98> (a java.util.LinkedList) at org.apache.activemq.ActiveMQMessageConsumer.dispatch(ActiveMQMessageConsumer.java:1231) - locked <0xfffffd7e8fc5c100> (a java.lang.Object) at org.apache.activemq.ActiveMQSessionExecutor.dispatch(ActiveMQSessionExecutor.java:134) at org.apache.activemq.ActiveMQSessionExecutor.execute(ActiveMQSessionExecutor.java:82) at org.apache.activemq.ActiveMQSession.dispatch(ActiveMQSession.java:1535) at org.apache.activemq.ActiveMQConnection$2.processMessageDispatch(ActiveMQConnection.java:1725) at org.apache.activemq.command.MessageDispatch.visit(MessageDispatch.java:108) at org.apache.activemq.ActiveMQConnection.onCommand(ActiveMQConnection.java:1706) at org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:116) at org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:69) at org.apache.activemq.transport.failover.FailoverTransport$3.onCommand(FailoverTransport.java:181) at org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:113) at org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityMonitor.java:228) - locked <0xfffffd7eb605c268> (a org.apache.activemq.transport.InactivityMonitor$1) at org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:83) at org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:220) at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:202) at java.lang.Thread.run(Thread.java:662) On the Broker : "BrokerService[ProdAMQBrokerperf4bc3b] Task" daemon prio=3 tid=0x000000000628b000 nid=0x9f2 runnable [0xfffffd7e4c9f3000] java.lang.Thread.State: RUNNABLE at java.net.SocketOutputStream.socketWrite0(Native Method) at java.net.SocketOutputStream.socketWrite(SocketOutputStream.java:92) at java.net.SocketOutputStream.write(SocketOutputStream.java:136) at org.apache.activemq.transport.tcp.TcpBufferedOutputStream.flush(TcpBufferedOutputStream.java:115) at java.io.DataOutputStream.flush(DataOutputStream.java:106) at org.apache.activemq.transport.tcp.TcpTransport.oneway(TcpTransport.java:182) at org.apache.activemq.transport.InactivityMonitor.oneway(InactivityMonitor.java:255) - locked <0xfffffd7e92fd6900> (a java.util.concurrent.atomic.AtomicBoolean) at org.apache.activemq.transport.TransportFilter.oneway(TransportFilter.java:85) at org.apache.activemq.transport.WireFormatNegotiator.oneway(WireFormatNegotiator.java:104) at org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.java:40) - locked <0xfffffd7e92fd6918> (a java.lang.Object) at org.apache.activemq.broker.TransportConnection.dispatch(TransportConnection.java:1258) at org.apache.activemq.broker.TransportConnection.processDispatch(TransportConnection.java:812) at org.apache.activemq.broker.TransportConnection.iterate(TransportConnection.java:855) at org.apache.activemq.thread.PooledTaskRunner.runTask(PooledTaskRunner.java:122) at org.apache.activemq.thread.PooledTaskRunner$1.run(PooledTaskRunner.java:43) at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908) at java.lang.Thread.run(Thread.java:662) "ActiveMQ Transport: tcp:///170.137.233.156:50613" daemon prio=3 tid=0x0000000005722800 nid=0x719 runnable [0xfffffd7e56e6c000] java.lang.Thread.State: RUNNABLE at java.net.SocketOutputStream.socketWrite0(Native Method) at java.net.SocketOutputStream.socketWrite(SocketOutputStream.java:92) at java.net.SocketOutputStream.write(SocketOutputStream.java:136) at org.apache.activemq.transport.tcp.TcpBufferedOutputStream.flush(TcpBufferedOutputStream.java:115) at java.io.DataOutputStream.flush(DataOutputStream.java:106) at org.apache.activemq.transport.tcp.TcpTransport.oneway(TcpTransport.java:182) at org.apache.activemq.transport.InactivityMonitor.oneway(InactivityMonitor.java:255) - locked <0xfffffd7e9408d088> (a java.util.concurrent.atomic.AtomicBoolean) at org.apache.activemq.transport.TransportFilter.oneway(TransportFilter.java:85) at org.apache.activemq.transport.WireFormatNegotiator.oneway(WireFormatNegotiator.java:104) at org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.java:40) - locked <0xfffffd7e9408ce60> (a java.lang.Object) at org.apache.activemq.broker.TransportConnection.dispatch(TransportConnection.java:1258) at org.apache.activemq.broker.TransportConnection.processDispatch(TransportConnection.java:812) at org.apache.activemq.broker.TransportConnection.dispatchSync(TransportConnection.java:772) at org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:187) at org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:69) at org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:113) at org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityMonitor.java:228) - locked <0xfffffd7e9408d100> (a org.apache.activemq.transport.InactivityMonitor$1) at org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:83) at org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:220) at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:202) at java.lang.Thread.run(Thread.java:662)