activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Adrian Tarau <...@daxtechnologies.com>
Subject ActiveMQ 3.2.2 and executor exceptions
Date Tue, 02 May 2006 14:13:53 GMT
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)


Mime
View raw message