You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@activemq.apache.org by Danielius Jurna <da...@elitnet.lt> on 2006/11/15 13:55:51 UTC
Consumer deadlock?
Hi.
I'm experiencing deadlocks in ActiveMQ broker. It's possible, that it is
because of client missbehaviour mentioned here:
http://www.nabble.com/Consumer-Deadlock-tf2014492.html#a5536571
I have thread dump from our production server. Can somebody take a look and
confirm or deny, that this is exactly the problem mentioned in posts above?
It's an urgen problem for us, so quick response would be very appreciated.
I'm not posting full dump (its a little too big, all whith the same call
stacks), but only interesting parts:
"ActiveMQ Transport: tcp:///192.168.111.17:1378" daemon prio=1
tid=0x0000002ac4e00a50 nid=0x686b runnable
[0x000000006ec38000..0x000000006ec39c30]
at java.util.Hashtable.get(Hashtable.java:335)
- waiting to lock <0x0000002aa17df278> (a
org.apache.derby.impl.services.locks.SinglePool)
at org.apache.derby.impl.services.locks.SinglePool.isLockHeld(Unknown
Source)
at
org.apache.derby.impl.store.access.PropertyConglomerate.iHoldTheUpdateLock(Unknown
Source)
at
org.apache.derby.impl.store.access.PropertyConglomerate.getProperty(Unknown
Source)
at org.apache.derby.impl.store.access.RAMTransaction.getProperty(Unknown
Source)
at
org.apache.derby.iapi.services.property.PropertyUtil.getDatabaseProperty(Unknown
Source)
at
org.apache.derby.iapi.services.property.PropertyUtil.getServiceProperty(Unknown
Source)
at
org.apache.derby.iapi.services.property.PropertyUtil.getServiceProperty(Unknown
Source)
at
org.apache.derby.iapi.services.property.PropertyUtil.getServiceInt(Unknown
Source)
at org.apache.derby.impl.store.raw.xact.Xact.setup(Unknown Source)
at
org.apache.derby.impl.store.access.RAMAccessManager.getAndNameTransaction(Unknown
Source)
at
org.apache.derby.impl.store.access.RAMAccessManager.getTransaction(Unknown
Source)
at org.apache.derby.impl.db.BasicDatabase.getConnectionTransaction(Unknown
Source)
at org.apache.derby.impl.db.BasicDatabase.setupConnection(Unknown Source)
at
org.apache.derby.impl.jdbc.TransactionResourceImpl.startTransaction(Unknown
Source)
at org.apache.derby.impl.jdbc.EmbedConnection.<init>(Unknown Source)
at org.apache.derby.impl.jdbc.EmbedConnection30.<init>(Unknown Source)
at org.apache.derby.jdbc.Driver30.getNewEmbedConnection(Unknown Source)
at org.apache.derby.jdbc.InternalDriver.connect(Unknown Source)
at org.apache.derby.jdbc.EmbeddedDataSource.getConnection(Unknown Source)
at org.apache.derby.jdbc.EmbeddedDataSource.getConnection(Unknown Source)
at
org.apache.activemq.store.jdbc.TransactionContext.getConnection(TransactionContext.java:55)
at
org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter.doGetMessage(DefaultJDBCAdapter.java:261)
at
org.apache.activemq.store.jdbc.JDBCMessageStore.getMessage(JDBCMessageStore.java:100)
at
org.apache.activemq.store.journal.JournalMessageStore.getMessage(JournalMessageStore.java:329)
at org.apache.activemq.broker.region.Queue.loadMessage(Queue.java:324)
at
org.apache.activemq.broker.region.IndirectMessageReference.incrementReferenceCount(IndirectMessageReference.java:109)
- locked <0x0000002aa4a3bd58> (a
org.apache.activemq.broker.region.IndirectMessageReference)
at
org.apache.activemq.broker.region.QueueSubscription.dispatch(QueueSubscription.java:150)
at
org.apache.activemq.broker.region.PrefetchSubscription.add(PrefetchSubscription.java:68)
- locked <0x0000002ab7443e48> (a
org.apache.activemq.broker.region.QueueSubscription)
at org.apache.activemq.broker.region.Queue.addSubscription(Queue.java:164)
- locked <0x0000002aa438c760> (a java.util.LinkedList)
at
org.apache.activemq.broker.region.AbstractRegion.addConsumer(AbstractRegion.java:172)
at
org.apache.activemq.broker.region.RegionBroker.addConsumer(RegionBroker.java:297)
at
org.apache.activemq.broker.BrokerFilter.addConsumer(BrokerFilter.java:74)
at
org.apache.activemq.advisory.AdvisoryBroker.addConsumer(AdvisoryBroker.java:78)
at
org.apache.activemq.broker.BrokerFilter.addConsumer(BrokerFilter.java:74)
at
org.apache.activemq.broker.MutableBrokerFilter.addConsumer(MutableBrokerFilter.java:87)
at
org.apache.activemq.broker.AbstractConnection.processAddConsumer(AbstractConnection.java:529)
at org.apache.activemq.command.ConsumerInfo.visit(ConsumerInfo.java:296)
at
org.apache.activemq.broker.AbstractConnection.service(AbstractConnection.java:237)
at
org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:61)
at
org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:92)
at
org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:67)
at
org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityMonitor.java:123)
at
org.apache.activemq.transport.stomp.StompTransportFilter.sendToActiveMQ(StompTransportFilter.java:70)
- locked <0x0000002ab6c21c28> (a java.lang.Object)
at
org.apache.activemq.transport.stomp.ProtocolConverter.sendToActiveMQ(ProtocolConverter.java:112)
at
org.apache.activemq.transport.stomp.ProtocolConverter.onStompSubscribe(ProtocolConverter.java:348)
at
org.apache.activemq.transport.stomp.ProtocolConverter.onStompCommad(ProtocolConverter.java:142)
at
org.apache.activemq.transport.stomp.StompTransportFilter.onCommand(StompTransportFilter.java:60)
at
org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:88)
at
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:137)
at java.lang.Thread.run(Thread.java:595)
"ActiveMQ Transport: tcp:///192.168.111.17:1377" daemon prio=1
tid=0x0000002ac4dff3d0 nid=0x685d in Object.wait()
[0x000000006ea37000..0x000000006ea37b30]
at java.lang.Object.wait(Native Method)
at java.lang.Object.wait(Object.java:474)
at
org.apache.activemq.memory.UsageManager.waitForSpace(UsageManager.java:86)
- locked <0x0000002aa17cf768> (a java.lang.Object)
at
org.apache.activemq.memory.UsageManager.waitForSpace(UsageManager.java:83)
at org.apache.activemq.broker.region.Topic.send(Topic.java:236)
at
org.apache.activemq.broker.region.AbstractRegion.send(AbstractRegion.java:226)
at
org.apache.activemq.broker.region.RegionBroker.send(RegionBroker.java:349)
at
org.apache.activemq.broker.TransactionBroker.send(TransactionBroker.java:193)
at org.apache.activemq.broker.BrokerFilter.send(BrokerFilter.java:114)
at
org.apache.activemq.broker.CompositeDestinationBroker.send(CompositeDestinationBroker.java:98)
at
org.apache.activemq.broker.MutableBrokerFilter.send(MutableBrokerFilter.java:127)
at
org.apache.activemq.broker.AbstractConnection.processMessage(AbstractConnection.java:433)
at
org.apache.activemq.command.ActiveMQMessage.visit(ActiveMQMessage.java:591)
at
org.apache.activemq.broker.AbstractConnection.service(AbstractConnection.java:237)
at
org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:61)
at
org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:92)
at
org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:67)
at
org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityMonitor.java:123)
at
org.apache.activemq.transport.stomp.StompTransportFilter.sendToActiveMQ(StompTransportFilter.java:70)
- locked <0x0000002aa80a5068> (a java.lang.Object)
at
org.apache.activemq.transport.stomp.ProtocolConverter.sendToActiveMQ(ProtocolConverter.java:112)
at
org.apache.activemq.transport.stomp.ProtocolConverter.onStompSend(ProtocolConverter.java:197)
at
org.apache.activemq.transport.stomp.ProtocolConverter.onStompCommad(ProtocolConverter.java:132)
at
org.apache.activemq.transport.stomp.StompTransportFilter.onCommand(StompTransportFilter.java:60)
at
org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:88)
at
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:137)
at java.lang.Thread.run(Thread.java:595)
"ActiveMQ Transport: tcp:///127.0.0.1:52587" daemon prio=1
tid=0x0000002ac5c1b530 nid=0x2982 in Object.wait()
[0x00000000456a6000..0x00000000456a6eb0]
at java.lang.Object.wait(Native Method)
at java.lang.Object.wait(Object.java:474)
at
org.apache.activemq.memory.UsageManager.waitForSpace(UsageManager.java:86)
- locked <0x0000002aa17cf768> (a java.lang.Object)
at
org.apache.activemq.memory.UsageManager.waitForSpace(UsageManager.java:83)
at org.apache.activemq.broker.region.Queue.send(Queue.java:249)
at
org.apache.activemq.broker.region.AbstractRegion.send(AbstractRegion.java:226)
at
org.apache.activemq.broker.region.RegionBroker.send(RegionBroker.java:346)
at
org.apache.activemq.broker.TransactionBroker.send(TransactionBroker.java:193)
at org.apache.activemq.broker.BrokerFilter.send(BrokerFilter.java:114)
at
org.apache.activemq.broker.CompositeDestinationBroker.send(CompositeDestinationBroker.java:98)
at
org.apache.activemq.broker.MutableBrokerFilter.send(MutableBrokerFilter.java:127)
at
org.apache.activemq.broker.AbstractConnection.processMessage(AbstractConnection.java:433)
at
org.apache.activemq.command.ActiveMQMessage.visit(ActiveMQMessage.java:591)
at
org.apache.activemq.broker.AbstractConnection.service(AbstractConnection.java:237)
at
org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:61)
at
org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:92)
at
org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:67)
at
org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:124)
at
org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityMonitor.java:123)
at
org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:88)
at
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:137)
at java.lang.Thread.run(Thread.java:595)
--
View this message in context: http://www.nabble.com/Consumer-deadlock--tf2635867.html#a7357085
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Re: Consumer deadlock?
Posted by Danielius Jurna <da...@elitnet.lt>.
It seems, that the broblem was realated to consumer deadlock, which was
mentioned in http://www.nabble.com/Consumer-Deadlock-tf2014492.html#a5536571
Increasing broker memory limit and applying limits to the queues, seems to
solve the problem.
Danielius Jurna wrote:
>
> We can only reproduce this on the production server while waiting for
> couple of days :-)
> But I wonder what "waiting to lock <0x0000002aa17df278> (a
> org.apache.derby.impl.services.locks.SinglePool) " means? I cannot find
> that object to be locked in any other thread. Is that possible?
>
> But interesting thing is that
>
--
View this message in context: http://www.nabble.com/Consumer-deadlock--tf2635867.html#a7439533
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Re: Consumer deadlock?
Posted by Danielius Jurna <da...@elitnet.lt>.
We can only reproduce this on the production server while waiting for couple
of days :-)
But I wonder what "waiting to lock <0x0000002aa17df278> (a
org.apache.derby.impl.services.locks.SinglePool) " means? I cannot find that
object to be locked in any other thread. Is that possible?
But interesting thing is that
James.Strachan wrote:
>
> Whoah, that looks like a bug in Derby to me. I wonder if its worth us
> upgrading to a newer Derby release. We're on 10.1.1.0 whereas it looks
> like Derby has released 10.2.1.6.
>
> I wonder can you reproduce with a newer Derby jar?
>
--
View this message in context: http://www.nabble.com/Consumer-deadlock--tf2635867.html#a7358200
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Re: Consumer deadlock?
Posted by James Strachan <ja...@gmail.com>.
Whoah, that looks like a bug in Derby to me. I wonder if its worth us
upgrading to a newer Derby release. We're on 10.1.1.0 whereas it looks
like Derby has released 10.2.1.6.
I wonder can you reproduce with a newer Derby jar?
On 11/15/06, Danielius Jurna <da...@elitnet.lt> wrote:
>
> Hi.
> I'm experiencing deadlocks in ActiveMQ broker. It's possible, that it is
> because of client missbehaviour mentioned here:
> http://www.nabble.com/Consumer-Deadlock-tf2014492.html#a5536571
> I have thread dump from our production server. Can somebody take a look and
> confirm or deny, that this is exactly the problem mentioned in posts above?
> It's an urgen problem for us, so quick response would be very appreciated.
> I'm not posting full dump (its a little too big, all whith the same call
> stacks), but only interesting parts:
>
> "ActiveMQ Transport: tcp:///192.168.111.17:1378" daemon prio=1
> tid=0x0000002ac4e00a50 nid=0x686b runnable
> [0x000000006ec38000..0x000000006ec39c30]
> at java.util.Hashtable.get(Hashtable.java:335)
> - waiting to lock <0x0000002aa17df278> (a
> org.apache.derby.impl.services.locks.SinglePool)
> at org.apache.derby.impl.services.locks.SinglePool.isLockHeld(Unknown
> Source)
> at
> org.apache.derby.impl.store.access.PropertyConglomerate.iHoldTheUpdateLock(Unknown
> Source)
> at
> org.apache.derby.impl.store.access.PropertyConglomerate.getProperty(Unknown
> Source)
> at org.apache.derby.impl.store.access.RAMTransaction.getProperty(Unknown
> Source)
> at
> org.apache.derby.iapi.services.property.PropertyUtil.getDatabaseProperty(Unknown
> Source)
> at
> org.apache.derby.iapi.services.property.PropertyUtil.getServiceProperty(Unknown
> Source)
> at
> org.apache.derby.iapi.services.property.PropertyUtil.getServiceProperty(Unknown
> Source)
> at
> org.apache.derby.iapi.services.property.PropertyUtil.getServiceInt(Unknown
> Source)
> at org.apache.derby.impl.store.raw.xact.Xact.setup(Unknown Source)
> at
> org.apache.derby.impl.store.access.RAMAccessManager.getAndNameTransaction(Unknown
> Source)
> at
> org.apache.derby.impl.store.access.RAMAccessManager.getTransaction(Unknown
> Source)
> at org.apache.derby.impl.db.BasicDatabase.getConnectionTransaction(Unknown
> Source)
> at org.apache.derby.impl.db.BasicDatabase.setupConnection(Unknown Source)
> at
> org.apache.derby.impl.jdbc.TransactionResourceImpl.startTransaction(Unknown
> Source)
> at org.apache.derby.impl.jdbc.EmbedConnection.<init>(Unknown Source)
> at org.apache.derby.impl.jdbc.EmbedConnection30.<init>(Unknown Source)
> at org.apache.derby.jdbc.Driver30.getNewEmbedConnection(Unknown Source)
> at org.apache.derby.jdbc.InternalDriver.connect(Unknown Source)
> at org.apache.derby.jdbc.EmbeddedDataSource.getConnection(Unknown Source)
> at org.apache.derby.jdbc.EmbeddedDataSource.getConnection(Unknown Source)
> at
> org.apache.activemq.store.jdbc.TransactionContext.getConnection(TransactionContext.java:55)
> at
> org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter.doGetMessage(DefaultJDBCAdapter.java:261)
> at
> org.apache.activemq.store.jdbc.JDBCMessageStore.getMessage(JDBCMessageStore.java:100)
> at
> org.apache.activemq.store.journal.JournalMessageStore.getMessage(JournalMessageStore.java:329)
> at org.apache.activemq.broker.region.Queue.loadMessage(Queue.java:324)
> at
> org.apache.activemq.broker.region.IndirectMessageReference.incrementReferenceCount(IndirectMessageReference.java:109)
> - locked <0x0000002aa4a3bd58> (a
> org.apache.activemq.broker.region.IndirectMessageReference)
> at
> org.apache.activemq.broker.region.QueueSubscription.dispatch(QueueSubscription.java:150)
> at
> org.apache.activemq.broker.region.PrefetchSubscription.add(PrefetchSubscription.java:68)
> - locked <0x0000002ab7443e48> (a
> org.apache.activemq.broker.region.QueueSubscription)
> at org.apache.activemq.broker.region.Queue.addSubscription(Queue.java:164)
> - locked <0x0000002aa438c760> (a java.util.LinkedList)
> at
> org.apache.activemq.broker.region.AbstractRegion.addConsumer(AbstractRegion.java:172)
> at
> org.apache.activemq.broker.region.RegionBroker.addConsumer(RegionBroker.java:297)
> at
> org.apache.activemq.broker.BrokerFilter.addConsumer(BrokerFilter.java:74)
> at
> org.apache.activemq.advisory.AdvisoryBroker.addConsumer(AdvisoryBroker.java:78)
> at
> org.apache.activemq.broker.BrokerFilter.addConsumer(BrokerFilter.java:74)
> at
> org.apache.activemq.broker.MutableBrokerFilter.addConsumer(MutableBrokerFilter.java:87)
> at
> org.apache.activemq.broker.AbstractConnection.processAddConsumer(AbstractConnection.java:529)
> at org.apache.activemq.command.ConsumerInfo.visit(ConsumerInfo.java:296)
> at
> org.apache.activemq.broker.AbstractConnection.service(AbstractConnection.java:237)
> at
> org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:61)
> at
> org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:92)
> at
> org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:67)
> at
> org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityMonitor.java:123)
> at
> org.apache.activemq.transport.stomp.StompTransportFilter.sendToActiveMQ(StompTransportFilter.java:70)
> - locked <0x0000002ab6c21c28> (a java.lang.Object)
> at
> org.apache.activemq.transport.stomp.ProtocolConverter.sendToActiveMQ(ProtocolConverter.java:112)
> at
> org.apache.activemq.transport.stomp.ProtocolConverter.onStompSubscribe(ProtocolConverter.java:348)
> at
> org.apache.activemq.transport.stomp.ProtocolConverter.onStompCommad(ProtocolConverter.java:142)
> at
> org.apache.activemq.transport.stomp.StompTransportFilter.onCommand(StompTransportFilter.java:60)
> at
> org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:88)
> at
> org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:137)
> at java.lang.Thread.run(Thread.java:595)
>
> "ActiveMQ Transport: tcp:///192.168.111.17:1377" daemon prio=1
> tid=0x0000002ac4dff3d0 nid=0x685d in Object.wait()
> [0x000000006ea37000..0x000000006ea37b30]
> at java.lang.Object.wait(Native Method)
> at java.lang.Object.wait(Object.java:474)
> at
> org.apache.activemq.memory.UsageManager.waitForSpace(UsageManager.java:86)
> - locked <0x0000002aa17cf768> (a java.lang.Object)
> at
> org.apache.activemq.memory.UsageManager.waitForSpace(UsageManager.java:83)
> at org.apache.activemq.broker.region.Topic.send(Topic.java:236)
> at
> org.apache.activemq.broker.region.AbstractRegion.send(AbstractRegion.java:226)
> at
> org.apache.activemq.broker.region.RegionBroker.send(RegionBroker.java:349)
> at
> org.apache.activemq.broker.TransactionBroker.send(TransactionBroker.java:193)
> at org.apache.activemq.broker.BrokerFilter.send(BrokerFilter.java:114)
> at
> org.apache.activemq.broker.CompositeDestinationBroker.send(CompositeDestinationBroker.java:98)
> at
> org.apache.activemq.broker.MutableBrokerFilter.send(MutableBrokerFilter.java:127)
> at
> org.apache.activemq.broker.AbstractConnection.processMessage(AbstractConnection.java:433)
> at
> org.apache.activemq.command.ActiveMQMessage.visit(ActiveMQMessage.java:591)
> at
> org.apache.activemq.broker.AbstractConnection.service(AbstractConnection.java:237)
> at
> org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:61)
> at
> org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:92)
> at
> org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:67)
> at
> org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityMonitor.java:123)
> at
> org.apache.activemq.transport.stomp.StompTransportFilter.sendToActiveMQ(StompTransportFilter.java:70)
> - locked <0x0000002aa80a5068> (a java.lang.Object)
> at
> org.apache.activemq.transport.stomp.ProtocolConverter.sendToActiveMQ(ProtocolConverter.java:112)
> at
> org.apache.activemq.transport.stomp.ProtocolConverter.onStompSend(ProtocolConverter.java:197)
> at
> org.apache.activemq.transport.stomp.ProtocolConverter.onStompCommad(ProtocolConverter.java:132)
> at
> org.apache.activemq.transport.stomp.StompTransportFilter.onCommand(StompTransportFilter.java:60)
> at
> org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:88)
> at
> org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:137)
> at java.lang.Thread.run(Thread.java:595)
>
> "ActiveMQ Transport: tcp:///127.0.0.1:52587" daemon prio=1
> tid=0x0000002ac5c1b530 nid=0x2982 in Object.wait()
> [0x00000000456a6000..0x00000000456a6eb0]
> at java.lang.Object.wait(Native Method)
> at java.lang.Object.wait(Object.java:474)
> at
> org.apache.activemq.memory.UsageManager.waitForSpace(UsageManager.java:86)
> - locked <0x0000002aa17cf768> (a java.lang.Object)
> at
> org.apache.activemq.memory.UsageManager.waitForSpace(UsageManager.java:83)
> at org.apache.activemq.broker.region.Queue.send(Queue.java:249)
> at
> org.apache.activemq.broker.region.AbstractRegion.send(AbstractRegion.java:226)
> at
> org.apache.activemq.broker.region.RegionBroker.send(RegionBroker.java:346)
> at
> org.apache.activemq.broker.TransactionBroker.send(TransactionBroker.java:193)
> at org.apache.activemq.broker.BrokerFilter.send(BrokerFilter.java:114)
> at
> org.apache.activemq.broker.CompositeDestinationBroker.send(CompositeDestinationBroker.java:98)
> at
> org.apache.activemq.broker.MutableBrokerFilter.send(MutableBrokerFilter.java:127)
> at
> org.apache.activemq.broker.AbstractConnection.processMessage(AbstractConnection.java:433)
> at
> org.apache.activemq.command.ActiveMQMessage.visit(ActiveMQMessage.java:591)
> at
> org.apache.activemq.broker.AbstractConnection.service(AbstractConnection.java:237)
> at
> org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:61)
> at
> org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:92)
> at
> org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:67)
> at
> org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:124)
> at
> org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityMonitor.java:123)
> at
> org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:88)
> at
> org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:137)
> at java.lang.Thread.run(Thread.java:595)
>
> --
> View this message in context: http://www.nabble.com/Consumer-deadlock--tf2635867.html#a7357085
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>
>
--
James
-------
http://radio.weblogs.com/0112098/