Try upgrade to 4.0-RC3 where this issue is fixed AFAIK
On 5/2/06, Adrian Tarau <[EMAIL PROTECTED]> wrote:
I have a few problems with consumers sometime I have this exceptions(see
bellow).
Anybody knows way "threadPool.execute(this);" gets InterruptedException?
Anybody got this exceptions?
Thanks.
[EMAIL PROTECTED]
Couldn't start executing
java.lang.InterruptedException
at
EDU.oswego.cs.dl.util.concurrent.SynchronousChannel.offer(SynchronousChannel.java:241)
at
EDU.oswego.cs.dl.util.concurrent.PooledExecutor.execute(PooledExecutor.java:885)
at
org.activemq.service.boundedvm.DurableQueueBoundedMessageContainer.checkRunning(DurableQueueBoundedMessageContainer.java:452)
at
org.activemq.service.boundedvm.DurableQueueBoundedMessageContainer.addConsumer(DurableQueueBoundedMessageContainer.java:139)
at
org.activemq.service.boundedvm.DurableQueueBoundedMessageManager.addMessageConsumer(DurableQueueBoundedMessageManager.java:225)
at
org.activemq.broker.impl.DefaultBroker.addMessageConsumer(DefaultBroker.java:267)
at
org.activemq.broker.impl.BrokerContainerImpl.registerMessageConsumer(BrokerContainerImpl.java:355)
at
org.activemq.broker.impl.BrokerConnectorImpl.registerMessageConsumer(BrokerConnectorImpl.java:180)
at
org.activemq.broker.impl.BrokerClientImpl.consumeConsumerInfo(BrokerClientImpl.java:506)
at
org.activemq.broker.impl.BrokerClientImpl.consume(BrokerClientImpl.java:358)
at
org.activemq.transport.vm.VmTransportChannel.asyncSend(VmTransportChannel.java:143)
at
org.activemq.transport.TransportChannelSupport.doAsyncSend(TransportChannelSupport.java:433)
at
org.activemq.transport.TransportChannelSupport.asyncSendWithReceipt(TransportChannelSupport.java:160)
at
org.activemq.transport.TransportChannelSupport.send(TransportChannelSupport.java:145)
at
org.activemq.ActiveMQConnection.syncSendPacket(ActiveMQConnection.java:1388)
at
org.activemq.ActiveMQConnection.syncSendPacket(ActiveMQConnection.java:1373)
at org.activemq.ActiveMQSession.addConsumer(ActiveMQSession.java:1199)
at
org.activemq.ActiveMQMessageConsumer.<init>(ActiveMQMessageConsumer.java:145)
at org.activemq.ActiveMQSession.createConsumer(ActiveMQSession.java:616)
-------------------------------------------------------------------------------------------------------------------------------------------------------------------------
Couldn't start executing
java.lang.InterruptedException
at
EDU.oswego.cs.dl.util.concurrent.SynchronousChannel.offer(SynchronousChannel.java:241)
at
EDU.oswego.cs.dl.util.concurrent.PooledExecutor.execute(PooledExecutor.java:885)
at
org.activemq.service.boundedvm.DurableQueueBoundedMessageContainer.checkRunning(DurableQueueBoundedMessageContainer.java:452)
at
org.activemq.service.boundedvm.DurableQueueBoundedMessageContainer.addConsumer(DurableQueueBoundedMessageContainer.java:139)
at
org.activemq.service.boundedvm.DurableQueueBoundedMessageManager.addMessageConsumer(DurableQueueBoundedMessageManager.java:225)
at
org.activemq.broker.impl.DefaultBroker.addMessageConsumer(DefaultBroker.java:267)
at
org.activemq.broker.impl.BrokerContainerImpl.registerMessageConsumer(BrokerContainerImpl.java:355)
at
org.activemq.broker.impl.BrokerConnectorImpl.registerMessageConsumer(BrokerConnectorImpl.java:180)
at
org.activemq.broker.impl.BrokerClientImpl.consumeConsumerInfo(BrokerClientImpl.java:506)
at
org.activemq.broker.impl.BrokerClientImpl.consume(BrokerClientImpl.java:358)
at
org.activemq.transport.vm.VmTransportChannel.asyncSend(VmTransportChannel.java:143)
at
org.activemq.transport.TransportChannelSupport.doAsyncSend(TransportChannelSupport.java:433)
at
org.activemq.transport.TransportChannelSupport.asyncSendWithReceipt(TransportChannelSupport.java:160)
at
org.activemq.transport.TransportChannelSupport.send(TransportChannelSupport.java:145)
at
org.activemq.ActiveMQConnection.syncSendPacket(ActiveMQConnection.java:1388)
at
org.activemq.ActiveMQConnection.syncSendPacket(ActiveMQConnection.java:1373)
at org.activemq.ActiveMQSession.addConsumer(ActiveMQSession.java:1199)
at
org.activemq.ActiveMQMessageConsumer.<init>(ActiveMQMessageConsumer.java:145)
at org.activemq.ActiveMQSession.createConsumer(ActiveMQSession.java:616)
-------------------------------------------------------------------------------------------------------------------------------------------------------------------------
javax.jms.JMSException:
[EMAIL PROTECTED]
Failed to start running dispatch thread
at
org.activemq.service.boundedvm.TransientQueueBoundedMessageContainer.addConsumer(TransientQueueBoundedMessageContainer.java:144)
at
org.activemq.service.boundedvm.TransientQueueBoundedMessageManager.addMessageConsumer(TransientQueueBoundedMessageManager.java:226)
at
org.activemq.broker.impl.DefaultBroker.addMessageConsumer(DefaultBroker.java:267)
at
org.activemq.broker.impl.BrokerContainerImpl.registerMessageConsumer(BrokerContainerImpl.java:355)
at
org.activemq.broker.impl.BrokerConnectorImpl.registerMessageConsumer(BrokerConnectorImpl.java:180)
at
org.activemq.broker.impl.BrokerClientImpl.consumeConsumerInfo(BrokerClientImpl.java:506)
at
org.activemq.broker.impl.BrokerClientImpl.consume(BrokerClientImpl.java:358)
at
org.activemq.transport.vm.VmTransportChannel.asyncSend(VmTransportChannel.java:143)
at
org.activemq.transport.TransportChannelSupport.doAsyncSend(TransportChannelSupport.java:433)
at
org.activemq.transport.TransportChannelSupport.asyncSendWithReceipt(TransportChannelSupport.java:160)
at
org.activemq.transport.TransportChannelSupport.send(TransportChannelSupport.java:145)
at
org.activemq.ActiveMQConnection.syncSendPacket(ActiveMQConnection.java:1388)
at
org.activemq.ActiveMQConnection.syncSendPacket(ActiveMQConnection.java:1373)
at org.activemq.ActiveMQSession.addConsumer(ActiveMQSession.java:1199)
at
org.activemq.ActiveMQMessageConsumer.<init>(ActiveMQMessageConsumer.java:145)
at org.activemq.ActiveMQSession.createConsumer(ActiveMQSession.java:616)
-------------------------------------------------------------------------------------------------------------------------------------------------------------------------
[EMAIL PROTECTED]
Couldn't start executing
java.lang.InterruptedException
at
EDU.oswego.cs.dl.util.concurrent.SynchronousChannel.offer(SynchronousChannel.java:241)
at
EDU.oswego.cs.dl.util.concurrent.PooledExecutor.execute(PooledExecutor.java:885)
at
org.activemq.service.boundedvm.DurableQueueBoundedMessageContainer.checkRunning(DurableQueueBoundedMessageContainer.java:452)
at
org.activemq.service.boundedvm.DurableQueueBoundedMessageContainer.addConsumer(DurableQueueBoundedMessageContainer.java:139)
at
org.activemq.service.boundedvm.DurableQueueBoundedMessageManager.addMessageConsumer(DurableQueueBoundedMessageManager.java:225)
at
org.activemq.broker.impl.DefaultBroker.addMessageConsumer(DefaultBroker.java:267)
at
org.activemq.broker.impl.BrokerContainerImpl.registerMessageConsumer(BrokerContainerImpl.java:355)
at
org.activemq.broker.impl.BrokerConnectorImpl.registerMessageConsumer(BrokerConnectorImpl.java:180)
at
org.activemq.broker.impl.BrokerClientImpl.consumeConsumerInfo(BrokerClientImpl.java:506)
at
org.activemq.broker.impl.BrokerClientImpl.consume(BrokerClientImpl.java:358)
at
org.activemq.transport.vm.VmTransportChannel.asyncSend(VmTransportChannel.java:143)
at
org.activemq.transport.TransportChannelSupport.doAsyncSend(TransportChannelSupport.java:433)
at
org.activemq.transport.TransportChannelSupport.asyncSendWithReceipt(TransportChannelSupport.java:160)
at
org.activemq.transport.TransportChannelSupport.send(TransportChannelSupport.java:145)
at
org.activemq.ActiveMQConnection.syncSendPacket(ActiveMQConnection.java:1388)
at
org.activemq.ActiveMQConnection.syncSendPacket(ActiveMQConnection.java:1373)
at org.activemq.ActiveMQSession.addConsumer(ActiveMQSession.java:1199)
at
org.activemq.ActiveMQMessageConsumer.<init>(ActiveMQMessageConsumer.java:145)
at org.activemq.ActiveMQSession.createConsumer(ActiveMQSession.java:616)
-------------------------------------------------------------------------------------------------------------------------------------------------------------------------
javax.jms.JMSException:
[EMAIL PROTECTED]
Failed to start running dispatch thread
at
org.activemq.service.boundedvm.TransientQueueBoundedMessageContainer.addConsumer(TransientQueueBoundedMessageContainer.java:144)
at
org.activemq.service.boundedvm.TransientQueueBoundedMessageManager.addMessageConsumer(TransientQueueBoundedMessageManager.java:226)
at
org.activemq.broker.impl.DefaultBroker.addMessageConsumer(DefaultBroker.java:267)
at
org.activemq.broker.impl.BrokerContainerImpl.registerMessageConsumer(BrokerContainerImpl.java:355)
at
org.activemq.broker.impl.BrokerConnectorImpl.registerMessageConsumer(BrokerConnectorImpl.java:180)
at
org.activemq.broker.impl.BrokerClientImpl.consumeConsumerInfo(BrokerClientImpl.java:506)
at
org.activemq.broker.impl.BrokerClientImpl.consume(BrokerClientImpl.java:358)
at
org.activemq.transport.vm.VmTransportChannel.asyncSend(VmTransportChannel.java:143)
at
org.activemq.transport.TransportChannelSupport.doAsyncSend(TransportChannelSupport.java:433)
at
org.activemq.transport.TransportChannelSupport.asyncSendWithReceipt(TransportChannelSupport.java:160)
at
org.activemq.transport.TransportChannelSupport.send(TransportChannelSupport.java:145)
at
org.activemq.ActiveMQConnection.syncSendPacket(ActiveMQConnection.java:1388)
at
org.activemq.ActiveMQConnection.syncSendPacket(ActiveMQConnection.java:1373)
at org.activemq.ActiveMQSession.addConsumer(ActiveMQSession.java:1199)
at
org.activemq.ActiveMQMessageConsumer.<init>(ActiveMQMessageConsumer.java:145)
at org.activemq.ActiveMQSession.createConsumer(ActiveMQSession.java:616)
--
James
-------
http://radio.weblogs.com/0112098/
