Yogeshkumar More created AMQ-7033:
-------------------------------------
Summary: Broker not cleaning up session during high message rate
Key: AMQ-7033
URL: https://issues.apache.org/jira/browse/AMQ-7033
Project: ActiveMQ
Issue Type: Bug
Components: Broker
Affects Versions: 5.15.4
Reporter: Yogeshkumar More
When we try to send large number of messages from multiple connections we see
that some of the sockets don't get cleaned up. We initially thought
[AMQ-6561|https://issues.apache.org/jira/browse/AMQ-6561] AMQ-6561 should have
fixed this. But even after upgrading the version to 5.15.4 we see socket leak.
Following stack trace proves that there is some blocking which is not clearing
up the sockets. This grows gradually and causes out of memory issue as we are
using non-persistent, embedded broker.
{code:java}
"ActiveMQ InactivityMonitor Worker" #17953 daemon prio=5 os_prio=0
tid=0x00007fdc64017800 nid=0xb27f waiting for monitor entry [0x00007fda48fce000]
java.lang.Thread.State: BLOCKED (on object monitor)
at
org.apache.activemq.broker.TransportConnection.stopAsync(TransportConnection.java:1136)
- waiting to lock <0x00000006c2339d58> (a
org.apache.activemq.broker.TransportConnection)
at
org.apache.activemq.broker.TransportConnection.stopAsync(TransportConnection.java:1131)
at
org.apache.activemq.broker.TransportConnection.serviceTransportException(TransportConnection.java:239)
at
org.apache.activemq.broker.TransportConnection$1.onException(TransportConnection.java:210)
at
org.apache.activemq.transport.TransportFilter.onException(TransportFilter.java:114)
at
org.apache.activemq.transport.TransportFilter.onException(TransportFilter.java:114)
at
org.apache.activemq.transport.WireFormatNegotiator.onException(WireFormatNegotiator.java:173)
at
org.apache.activemq.transport.AbstractInactivityMonitor.onException(AbstractInactivityMonitor.java:345)
at
org.apache.activemq.transport.AbstractInactivityMonitor$1$1.run(AbstractInactivityMonitor.java:92)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748){code}
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
