[AMQ-5906] stomp deadlock

• Type: Bug
• Status: Closed
• Priority: Critical
• Resolution: Incomplete
• Affects Version/s: 5.10.2
• Component/s: STOMP
• Assignee: Unassigned
• Reporter: guotie
• Created: 29/Jul/15 08:24
• Updated: 27/Aug/15 16:53
• Resolved: 27/Aug/15 16:53

Description

"ActiveMQ Transport: tcp:///10.123.96.85:59771@61613" daemon prio=10 tid=0x00007fc10c0dd800 nid=0x5562 waiting on condition [0x00007fc204298000]
java.lang.Thread.State: WAITING (parking)
at sun.misc.Unsafe.park(Native Method)

• parking to wait for <0x00000000c1ec26a0> (a java.util.concurrent.locks.ReentrantLock$NonfairSync)
  at java.util.concurrent.locks.LockSupport.park(LockSupport.java:186)
  at java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt(AbstractQueuedSynchronizer.java:834)
  at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireQueued(AbstractQueuedSynchronizer.java:867)
  at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquire(AbstractQueuedSynchronizer.java:1197)
  at java.util.concurrent.locks.ReentrantLock$NonfairSync.lock(ReentrantLock.java:214)
  at java.util.concurrent.locks.ReentrantLock.lock(ReentrantLock.java:290)
  at org.apache.activemq.transport.MutexTransport.onCommand(MutexTransport.java:43)
  at org.apache.activemq.transport.AbstractInactivityMonitor.onCommand(AbstractInactivityMonitor.java:270)
  at org.apache.activemq.transport.stomp.StompTransportFilter.sendToActiveMQ(StompTransportFilter.java:87)
  at org.apache.activemq.transport.stomp.ProtocolConverter.sendToActiveMQ(ProtocolConverter.java:199)
  at org.apache.activemq.transport.stomp.ProtocolConverter.onStompSend(ProtocolConverter.java:332)
  at org.apache.activemq.transport.stomp.ProtocolConverter.onStompCommand(ProtocolConverter.java:245)
  at org.apache.activemq.transport.stomp.StompTransportFilter.onCommand(StompTransportFilter.java:75)
  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)

"ActiveMQ BrokerService[localhost] Task-66475" daemon prio=10 tid=0x00007fc10c011800 nid=0x512a runnable [0x00007fc2054aa000]
java.lang.Thread.State: RUNNABLE
at java.net.SocketOutputStream.socketWrite0(Native Method)
at java.net.SocketOutputStream.socketWrite(SocketOutputStream.java:113)
at java.net.SocketOutputStream.write(SocketOutputStream.java:159)
at org.apache.activemq.transport.tcp.TcpBufferedOutputStream.write(TcpBufferedOutputStream.java:96)
at java.io.DataOutputStream.write(DataOutputStream.java:107)

• locked <0x00000000c1ec3368> (a java.io.DataOutputStream)
  at java.io.FilterOutputStream.write(FilterOutputStream.java:97)
  at org.apache.activemq.transport.stomp.StompWireFormat.marshal(StompWireFormat.java:89)
  at org.apache.activemq.transport.tcp.TcpTransport.oneway(TcpTransport.java:175)
  at org.apache.activemq.transport.stomp.StompTransportFilter.sendToStomp(StompTransportFilter.java:98)
  at org.apache.activemq.transport.stomp.StompSubscription.onMessageDispatch(StompSubscription.java:103)
  at org.apache.activemq.transport.stomp.ProtocolConverter.onActiveMQCommand(ProtocolConverter.java:871)
  at org.apache.activemq.transport.stomp.StompTransportFilter.oneway(StompTransportFilter.java:62)
  at org.apache.activemq.transport.AbstractInactivityMonitor.doOnewaySend(AbstractInactivityMonitor.java:304)
  at org.apache.activemq.transport.AbstractInactivityMonitor.oneway(AbstractInactivityMonitor.java:286)
  at org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.java:68)
  at org.apache.activemq.broker.TransportConnection.dispatch(TransportConnection.java:1415)
  at org.apache.activemq.broker.TransportConnection.processDispatch(TransportConnection.java:934)
  at org.apache.activemq.broker.TransportConnection.iterate(TransportConnection.java:980)
  at org.apache.activemq.thread.PooledTaskRunner.runTask(PooledTaskRunner.java:133)
  at org.apache.activemq.thread.PooledTaskRunner$1.run(PooledTaskRunner.java:48)
  at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
  at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
  at java.lang.Thread.run(Thread.java:745)