activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Aravind Chennuru <Aravind.Chenn...@netboss.com>
Subject ActiveMQ locking all the threads [5.5.1]
Date Tue, 06 Nov 2012 16:49:20 GMT
Hi All,

I am facing a problem on some of our production servers with ActiveMQ locking the threads
and the messages are no more sent to the consumers. Did someone notice similar problem and
know if there is a way to address this?
It is not a deadlock but when this happens the messages are stopped being sent.


"ActiveMQ Transport: tcp:///192.168.18.129:57610" daemon prio=3 tid=0x00000001027aa000 nid=0x3a
waiting for monitor entry [0xfffffffee6efe000]
   java.lang.Thread.State: BLOCKED (on object monitor)
                at org.apache.activemq.broker.region.Topic.doMessageSend(Topic.java:423)
                - waiting to lock <0xffffffff005397c0> (a org.apache.activemq.broker.region.Topic)
                at org.apache.activemq.broker.region.Topic.send(Topic.java:404)
                at org.apache.activemq.broker.region.AbstractRegion.send(AbstractRegion.java:365)
                at org.apache.activemq.broker.region.RegionBroker.send(RegionBroker.java:523)
                at org.apache.activemq.broker.BrokerFilter.send(BrokerFilter.java:129)
                at org.apache.activemq.broker.CompositeDestinationBroker.send(CompositeDestinationBroker.java:96)
                at org.apache.activemq.broker.TransactionBroker.send(TransactionBroker.java:227)
                at org.apache.activemq.broker.BrokerFilter.send(BrokerFilter.java:129)
                at org.apache.activemq.broker.MutableBrokerFilter.send(MutableBrokerFilter.java:135)
                at org.apache.activemq.broker.TransportConnection.processMessage(TransportConnection.java:458)
                at org.apache.activemq.command.ActiveMQMessage.visit(ActiveMQMessage.java:681)
                at org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:306)
                at org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:179)
                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:227)
                - locked <0xffffffff00767bb8> (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)

"ActiveMQ Transport: tcp:///192.168.18.130:40617" daemon prio=3 tid=0x0000000102f53000 nid=0x46
runnable [0xfffffffee60fe000]
   java.lang.Thread.State: RUNNABLE
                at java.io.RandomAccessFile.readBytes(Native Method)
                at java.io.RandomAccessFile.read(RandomAccessFile.java:338)
                at java.io.RandomAccessFile.readFully(RandomAccessFile.java:397)
                at java.io.RandomAccessFile.readFully(RandomAccessFile.java:377)
                at org.apache.kahadb.page.PageFile.readPage(PageFile.java:779)
                at org.apache.kahadb.page.Transaction$2.readPage(Transaction.java:440)
                at org.apache.kahadb.page.Transaction$2.<init>(Transaction.java:431)
                at org.apache.kahadb.page.Transaction.openInputStream(Transaction.java:428)
                at org.apache.kahadb.page.Transaction.load(Transaction.java:404)
                at org.apache.kahadb.page.Transaction.load(Transaction.java:361)
                at org.apache.activemq.store.kahadb.plist.PList.loadEntry(PList.java:468)
                at org.apache.activemq.store.kahadb.plist.PList.getNext(PList.java:483)
                at org.apache.activemq.store.kahadb.plist.PList$10.execute(PList.java:312)
                at org.apache.kahadb.page.Transaction.execute(Transaction.java:728)
                at org.apache.activemq.store.kahadb.plist.PList.getNext(PList.java:310)
                - locked <0xffffffff004de4c0> (a java.lang.Object)
                - locked <0xffffffff09a97068> (a org.apache.activemq.store.kahadb.plist.PList)
                at org.apache.activemq.broker.region.cursors.FilePendingMessageCursor$DiskIterator.next(FilePendingMessageCursor.java:500)
                - locked <0xffffffff09a97068> (a org.apache.activemq.store.kahadb.plist.PList)
                at org.apache.activemq.broker.region.cursors.FilePendingMessageCursor$DiskIterator.next(FilePendingMessageCursor.java:473)
                at org.apache.activemq.broker.region.cursors.FilePendingMessageCursor.next(FilePendingMessageCursor.java:293)
                - locked <0xffffffff013199f0> (a org.apache.activemq.broker.region.cursors.FilePendingMessageCursor)
                at org.apache.activemq.broker.region.TopicSubscription.removeExpiredMessages(TopicSubscription.java:212)
                at org.apache.activemq.broker.region.TopicSubscription.add(TopicSubscription.java:149)
                - locked <0xffffffff01316480> (a java.lang.Object)
                at org.apache.activemq.broker.region.policy.SimpleDispatchPolicy.dispatch(SimpleDispatchPolicy.java:48)
                at org.apache.activemq.broker.region.Topic.dispatch(Topic.java:634)
                at org.apache.activemq.broker.region.Topic.doMessageSend(Topic.java:468)
                - locked <0xffffffff005397c0> (a org.apache.activemq.broker.region.Topic)
                at org.apache.activemq.broker.region.Topic.send(Topic.java:404)
                at org.apache.activemq.broker.region.AbstractRegion.send(AbstractRegion.java:365)
                at org.apache.activemq.broker.region.RegionBroker.send(RegionBroker.java:523)
                at org.apache.activemq.broker.BrokerFilter.send(BrokerFilter.java:129)
                at org.apache.activemq.broker.CompositeDestinationBroker.send(CompositeDestinationBroker.java:96)
                at org.apache.activemq.broker.TransactionBroker.send(TransactionBroker.java:227)
                at org.apache.activemq.broker.BrokerFilter.send(BrokerFilter.java:129)
                at org.apache.activemq.broker.MutableBrokerFilter.send(MutableBrokerFilter.java:135)
                at org.apache.activemq.broker.TransportConnection.processMessage(TransportConnection.java:458)
                at org.apache.activemq.command.ActiveMQMessage.visit(ActiveMQMessage.java:681)
                at org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:306)
                at org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:179)
                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:227)
                - locked <0xffffffff004ca288> (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)

Thanks & Regards,
Aravind Chennuru

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message