activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From mlukica <ma...@tis.hr>
Subject deadlock on message expiration
Date Wed, 04 Jun 2008 11:17:07 GMT

Detected deadlock in AMQ 5.1.0 between transport thread (removing consumer)
and QueueThread (sending expired messages to DLQ):

Name: VMTransport
State: BLOCKED on java.lang.Object@7176e6 owned by:
QueueThread:queue://some_queue
Total blocked: 31  Total waited: 525

Stack trace: 
at
org.apache.activemq.broker.region.PrefetchSubscription.remove(PrefetchSubscription.java:463)
at
org.apache.activemq.broker.region.Queue.removeSubscription(Queue.java:300)
   - locked java.util.ArrayList@14aa305
at
org.apache.activemq.broker.region.AbstractRegion.removeConsumer(AbstractRegion.java:313)
   - locked java.lang.Object@da6a6b
at
org.apache.activemq.broker.region.RegionBroker.removeConsumer(RegionBroker.java:400)
at
org.apache.activemq.broker.BrokerFilter.removeConsumer(BrokerFilter.java:113)
at
org.apache.activemq.advisory.AdvisoryBroker.removeConsumer(AdvisoryBroker.java:222)
at
org.apache.activemq.broker.BrokerFilter.removeConsumer(BrokerFilter.java:113)
at
org.apache.activemq.broker.MutableBrokerFilter.removeConsumer(MutableBrokerFilter.java:120)
at
org.apache.activemq.broker.TransportConnection.processRemoveConsumer(TransportConnection.java:552)
at org.apache.activemq.command.RemoveInfo.visit(RemoveInfo.java:64)
at
org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:292)
at
org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:180)
at
org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:104)
at
org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:68)
at
org.apache.activemq.transport.vm.VMTransport.iterate(VMTransport.java:205)
at
org.apache.activemq.thread.PooledTaskRunner.runTask(PooledTaskRunner.java:122)
at
org.apache.activemq.thread.PooledTaskRunner$1.run(PooledTaskRunner.java:43)
java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
java.lang.Thread.run(Thread.java:619)

Name: QueueThread:queue://some_queue
State: BLOCKED on java.lang.Object@da6a6b owned by: VMTransport
Total blocked: 107  Total waited: 1.363

Stack trace: 
at
org.apache.activemq.broker.region.AbstractRegion.lookup(AbstractRegion.java:372)
at
org.apache.activemq.broker.region.AbstractRegion.send(AbstractRegion.java:336)
at
org.apache.activemq.broker.region.RegionBroker.send(RegionBroker.java:445)
at
org.apache.activemq.broker.TransactionBroker.send(TransactionBroker.java:224)
at org.apache.activemq.broker.BrokerFilter.send(BrokerFilter.java:125)
at
org.apache.activemq.broker.CompositeDestinationBroker.send(CompositeDestinationBroker.java:95)
at
org.apache.activemq.broker.MutableBrokerFilter.send(MutableBrokerFilter.java:132)
at org.apache.activemq.util.BrokerSupport.resend(BrokerSupport.java:56)
at
org.apache.activemq.broker.region.RegionBroker.sendToDeadLetterQueue(RegionBroker.java:712)
at
org.apache.activemq.broker.BrokerFilter.sendToDeadLetterQueue(BrokerFilter.java:257)
at
org.apache.activemq.broker.BrokerFilter.sendToDeadLetterQueue(BrokerFilter.java:257)
at
org.apache.activemq.broker.BrokerFilter.sendToDeadLetterQueue(BrokerFilter.java:257)
at
org.apache.activemq.broker.MutableBrokerFilter.sendToDeadLetterQueue(MutableBrokerFilter.java:270)
at
org.apache.activemq.broker.region.RegionBroker.messageExpired(RegionBroker.java:679)
at
org.apache.activemq.broker.region.PrefetchSubscription.dispatchPending(PrefetchSubscription.java:496)
   - locked java.lang.Object@7176e6
at
org.apache.activemq.broker.region.PrefetchSubscription.add(PrefetchSubscription.java:144)
at org.apache.activemq.broker.region.Queue.iterate(Queue.java:936)
   - locked org.apache.activemq.broker.region.Queue$2@e02b5
at
org.apache.activemq.thread.DeterministicTaskRunner.runTask(DeterministicTaskRunner.java:84)
at
org.apache.activemq.thread.DeterministicTaskRunner$1.run(DeterministicTaskRunner.java:41)
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:619)

-- 
View this message in context: http://www.nabble.com/deadlock-on-message-expiration-tp17644346s2354p17644346.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.


Mime
View raw message