activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "James Strachan" <james.strac...@gmail.com>
Subject Re: ActiveMQ 3.2.2 and executor exceptions
Date Tue, 02 May 2006 14:25:47 GMT
Try upgrade to 4.0-RC3 where this issue is fixed AFAIK

On 5/2/06, Adrian Tarau <ady@daxtechnologies.com> 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.
>
> org.activemq.service.boundedvm.DurableQueueBoundedMessageContainer@1f81efb
> 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:
> org.activemq.service.boundedvm.TransientQueueBoundedMessageContainer@108f060
> 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)
>
> -------------------------------------------------------------------------------------------------------------------------------------------------------------------------
>
> org.activemq.service.boundedvm.DurableQueueBoundedMessageContainer@28bda
> 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:
> org.activemq.service.boundedvm.TransientQueueBoundedMessageContainer@393527
> 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/

Mime
View raw message