activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Aravind Chennuru <Aravind.Chenn...@netboss.com>
Subject RE: ActiveMQ locking all the threads [5.5.1]
Date Tue, 06 Nov 2012 18:44:38 GMT
I attached the email about the way we use ActiveMQ, including the configuration file we used
to start ActiveMQ.







-----Original Message-----
From: Gaurav Sharma [mailto:gaurav.cs.sharma@gmail.com]
Sent: Tuesday, November 06, 2012 12:31 PM
To: users@activemq.apache.org
Subject: Re: ActiveMQ locking all the threads [5.5.1]



Mind sharing the messaging topology and how the broker is getting used by the app?



On Nov 6, 2012, at 8:49, Aravind Chennuru <Aravind.Chennuru@netboss.com<mailto:Aravind.Chennuru@netboss.com>>
wrote:



> 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
View raw message