8 Replies Latest reply on Apr 19, 2013 5:38 AM by cheekychops_smithcolina

Exhausted after delivery attempt: 1 IllegalStateException:Session closed

shenzy_shency.revindran Mar 23, 2013 9:02 AM

Hi,

I am using Fuse 1.7.0.

I am receiving a message in inbound queue. I want to wiretape that message to monitoring queue and then do a content based routing to a reporting queue.

below is my route definition

<log message="Sending $ to reporting queue" /> <to uri="{{cbr.outbound.reporting.queue}}" /> </when> <otherwise> <log message="Not a reporting message, not routed to reporting queue"/> </otherwise> </choice> </route> The wiretaping is working perfect, and I see the message reaching monitoring queue. But I get the below error when camel try to send the same message to the reporting queue. Failed delivery for (MessageId: ID:LON01-00178-64094-1364037406356-1:1:1:1:1 on ExchangeId: ID-LON01-00178-63970-1364037235286-0-1). Exhausted after delivery attempt: 1 caught: org.springframework.jms.IllegalStateException: The Session is closed; nested exception is javax.jms.IllegalStateException: The Session is closed org.springframework.jms.IllegalStateException: The Session is closed; nested exception is javax.jms.IllegalStateException: The Session is closed at org.springframework.jms.support.JmsUtils.convertJmsAccessException(JmsUtils.java:279)[104:org.springframework.jms:3.0.7.RELEASE] at org.springframework.jms.support.JmsAccessor.convertJmsAccessException(JmsAccessor.java:168)[104:org.springframework.jms:3.0.7.RELEASE] at org.springframework.jms.core.JmsTemplate.execute(JmsTemplate.java:469)[104:org.springframework.jms:3.0.7.RELEASE] at org.apache.camel.component.jms.JmsConfiguration$CamelJmsTemplate.send(JmsConfiguration.java:170)[105:org.apache.camel.camel-jms:2.10.0.fuse-71-047] at org.apache.camel.component.jms.JmsProducer.doSend(JmsProducer.java:402)[105:org.apache.camel.camel-jms:2.10.0.fuse-71-047] at org.apache.camel.component.jms.JmsProducer.processInOnly(JmsProducer.java:356)[105:org.apache.camel.camel-jms:2.10.0.fuse-71-047] at org.apache.camel.component.jms.JmsProducer.process(JmsProducer.java:132)[105:org.apache.camel.camel-jms:2.10.0.fuse-71-047] at org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73)[73:org.apache.camel.camel-core:2.10.0.fuse-71-047] at org.apache.camel.processor.SendProcessor$2.doInAsyncProducer(SendProcessor.java:122)[73:org.apache.camel.camel-core:2.10.0.fuse-71-047] at org.apache.camel.impl.ProducerCache.doInAsyncProducer(ProducerCache.java:298)[73:org.apache.camel.camel-core:2.10.0.fuse-71-047] at org.apache.camel.processor.SendProcessor.process(SendProcessor.java:117)[73:org.apache.camel.camel-core:2.10.0.fuse-71-047] at org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73)[73:org.apache.camel.camel-core:2.10.0.fuse-71-047] at org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:99)[73:org.apache.camel.camel-core:2.10.0.fuse-71-047] at org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90)[73:org.apache.camel.camel-core:2.10.0.fuse-71-047] at org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:73)[73:org.apache.camel.camel-core:2.10.0.fuse-71-047] at org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73)[73:org.apache.camel.camel-core:2.10.0.fuse-71-047] at org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:99)[73:org.apache.camel.camel-core:2.10.0.fuse-71-047] at org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90)[73:org.apache.camel.camel-core:2.10.0.fuse-71-047] at org.apache.camel.processor.interceptor.TraceInterceptor.process(TraceInterceptor.java:91)[73:org.apache.camel.camel-core:2.10.0.fuse-71-047] at org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73)[73:org.apache.camel.camel-core:2.10.0.fuse-71-047] at org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:99)[73:org.apache.camel.camel-core:2.10.0.fuse-71-047] at org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90)[73:org.apache.camel.camel-core:2.10.0.fuse-71-047] at org.apache.camel.fabric.FabricTraceProcessor.process(FabricTraceProcessor.java:81)[73:org.apache.camel.camel-core:2.10.0.fuse-71-047] at org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73)[73:org.apache.camel.camel-core:2.10.0.fuse-71-047] at org.apache.camel.processor.RedeliveryErrorHandler.processErrorHandler(RedeliveryErrorHandler.java:334)[73:org.apache.camel.camel-core:2.10.0.fuse-71-047] at org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:220)[73:org.apache.camel.camel-core:2.10.0.fuse-71-047] at org.apache.camel.processor.RouteContextProcessor.processNext(RouteContextProcessor.java:45)[73:org.apache.camel.camel-core:2.10.0.fuse-71-047] at org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90)[73:org.apache.camel.camel-core:2.10.0.fuse-71-047] at org.apache.camel.processor.interceptor.DefaultChannel.process(DefaultChannel.java:303)[73:org.apache.camel.camel-core:2.10.0.fuse-71-047] at org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73)[73:org.apache.camel.camel-core:2.10.0.fuse-71-047] at org.apache.camel.processor.Pipeline.process(Pipeline.java:117)[73:org.apache.camel.camel-core:2.10.0.fuse-71-047] at org.apache.camel.processor.Pipeline.process(Pipeline.java:80)[73:org.apache.camel.camel-core:2.10.0.fuse-71-047] at org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73)[73:org.apache.camel.camel-core:2.10.0.fuse-71-047] at org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:99)[73:org.apache.camel.camel-core:2.10.0.fuse-71-047] at org.apache.camel.processor.ChoiceProcessor.process(ChoiceProcessor.java:81)[73:org.apache.camel.camel-core:2.10.0.fuse-71-047] at org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73)[73:org.apache.camel.camel-core:2.10.0.fuse-71-047] at org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:99)[73:org.apache.camel.camel-core:2.10.0.fuse-71-047] at org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90)[73:org.apache.camel.camel-core:2.10.0.fuse-71-047] at org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:73)[73:org.apache.camel.camel-core:2.10.0.fuse-71-047] at org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73)[73:org.apache.camel.camel-core:2.10.0.fuse-71-047] at org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:99)[73:org.apache.camel.camel-core:2.10.0.fuse-71-047] at org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90)[73:org.apache.camel.camel-core:2.10.0.fuse-71-047] at org.apache.camel.processor.interceptor.TraceInterceptor.process(TraceInterceptor.java:91)[73:org.apache.camel.camel-core:2.10.0.fuse-71-047] at org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73)[73:org.apache.camel.camel-core:2.10.0.fuse-71-047] at org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:99)[73:org.apache.camel.camel-core:2.10.0.fuse-71-047] at org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90)[73:org.apache.camel.camel-core:2.10.0.fuse-71-047] at org.apache.camel.fabric.FabricTraceProcessor.process(FabricTraceProcessor.java:81)[73:org.apache.camel.camel-core:2.10.0.fuse-71-047] at org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73)[73:org.apache.camel.camel-core:2.10.0.fuse-71-047] at org.apache.camel.processor.RedeliveryErrorHandler.processErrorHandler(RedeliveryErrorHandler.java:334)[73:org.apache.camel.camel-core:2.10.0.fuse-71-047] at org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:220)[73:org.apache.camel.camel-core:2.10.0.fuse-71-047] at org.apache.camel.processor.RouteContextProcessor.processNext(RouteContextProcessor.java:45)[73:org.apache.camel.camel-core:2.10.0.fuse-71-047] at org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90)[73:org.apache.camel.camel-core:2.10.0.fuse-71-047] at org.apache.camel.processor.interceptor.DefaultChannel.process(DefaultChannel.java:303)[73:org.apache.camel.camel-core:2.10.0.fuse-71-047] at org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73)[73:org.apache.camel.camel-core:2.10.0.fuse-71-047] at org.apache.camel.processor.Pipeline.process(Pipeline.java:117)[73:org.apache.camel.camel-core:2.10.0.fuse-71-047] at org.apache.camel.processor.Pipeline.process(Pipeline.java:80)[73:org.apache.camel.camel-core:2.10.0.fuse-71-047] at org.apache.camel.processor.RouteContextProcessor.processNext(RouteContextProcessor.java:45)[73:org.apache.camel.camel-core:2.10.0.fuse-71-047] at org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90)[73:org.apache.camel.camel-core:2.10.0.fuse-71-047] at org.apache.camel.processor.UnitOfWorkProcessor.processAsync(UnitOfWorkProcessor.java:150)[73:org.apache.camel.camel-core:2.10.0.fuse-71-047] at org.apache.camel.processor.UnitOfWorkProcessor.process(UnitOfWorkProcessor.java:117)[73:org.apache.camel.camel-core:2.10.0.fuse-71-047] at org.apache.camel.processor.RouteInflightRepositoryProcessor.processNext(RouteInflightRepositoryProcessor.java:48)[73:org.apache.camel.camel-core:2.10.0.fuse-71-047] at org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90)[73:org.apache.camel.camel-core:2.10.0.fuse-71-047] at org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73)[73:org.apache.camel.camel-core:2.10.0.fuse-71-047] at org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:99)[73:org.apache.camel.camel-core:2.10.0.fuse-71-047] at org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90)[73:org.apache.camel.camel-core:2.10.0.fuse-71-047] at org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:73)[73:org.apache.camel.camel-core:2.10.0.fuse-71-047] at org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:99)[73:org.apache.camel.camel-core:2.10.0.fuse-71-047] at org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:86)[73:org.apache.camel.camel-core:2.10.0.fuse-71-047] at org.apache.camel.component.jms.EndpointMessageListener.onMessage(EndpointMessageListener.java:104)[105:org.apache.camel.camel-jms:2.10.0.fuse-71-047] at org.springframework.jms.listener.AbstractMessageListenerContainer.doInvokeListener(AbstractMessageListenerContainer.java:560)[104:org.springframework.jms:3.0.7.RELEASE] at org.springframework.jms.listener.AbstractMessageListenerContainer.invokeListener(AbstractMessageListenerContainer.java:498)[104:org.springframework.jms:3.0.7.RELEASE] at org.springframework.jms.listener.AbstractMessageListenerContainer.doExecuteListener(AbstractMessageListenerContainer.java:467)[104:org.springframework.jms:3.0.7.RELEASE] at org.springframework.jms.listener.AbstractPollingMessageListenerContainer.doReceiveAndExecute(AbstractPollingMessageListenerContainer.java:325)[104:org.springframework.jms:3.0.7.RELEASE] at org.springframework.jms.listener.AbstractPollingMessageListenerContainer.receiveAndExecute(AbstractPollingMessageListenerContainer.java:263)[104:org.springframework.jms:3.0.7.RELEASE] at org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.invokeListener(DefaultMessageListenerContainer.java:1058)[104:org.springframework.jms:3.0.7.RELEASE] at org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.executeOngoingLoop(DefaultMessageListenerContainer.java:1050)[104:org.springframework.jms:3.0.7.RELEASE] at org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.run(DefaultMessageListenerContainer.java:947)[104:org.springframework.jms:3.0.7.RELEASE] at java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)[:1.7.0_10] at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)[:1.7.0_10] at java.lang.Thread.run(Unknown Source)[:1.7.0_10] Caused by: javax.jms.IllegalStateException: The Session is closed at org.apache.activemq.ActiveMQSession.checkClosed(ActiveMQSession.java:731)[124:org.apache.activemq.activemq-core:5.7.0.fuse-71-047] at org.apache.activemq.ActiveMQSession.createQueue(ActiveMQSession.java:1169)[124:org.apache.activemq.activemq-core:5.7.0.fuse-71-047] at org.apache.activemq.pool.PooledSession.createQueue(PooledSession.java:193)[97:org.apache.activemq.activemq-pool:5.7.0.fuse-71-047] at org.springframework.jms.support.destination.DynamicDestinationResolver.resolveQueue(DynamicDestinationResolver.java:101)[104:org.springframework.jms:3.0.7.RELEASE] at org.springframework.jms.support.destination.DynamicDestinationResolver.resolveDestinationName(DynamicDestinationResolver.java:66)[104:org.springframework.jms:3.0.7.RELEASE] at org.springframework.jms.support.destination.JmsDestinationAccessor.resolveDestinationName(JmsDestinationAccessor.java:100)[104:org.springframework.jms:3.0.7.RELEASE] at org.apache.camel.component.jms.JmsConfiguration$CamelJmsTemplate.access$000(JmsConfiguration.java:159)[105:org.apache.camel.camel-jms:2.10.0.fuse-71-047] at org.apache.camel.component.jms.JmsConfiguration$CamelJmsTemplate$1.doInJms(JmsConfiguration.java:172)[105:org.apache.camel.camel-jms:2.10.0.fuse-71-047] at org.springframework.jms.core.JmsTemplate.execute(JmsTemplate.java:466)[104:org.springframework.jms:3.0.7.RELEASE] ... 77 more 2013-03-23 11:16:46,525 | WARN | .155:61616@64046 | FailoverTransport | sport.failover.FailoverTransport 255 | 124 - org.apache.activemq.activemq-core - 5.7.0.fuse-71-047 | Transport (tcp://10.50.1.155:61616) failed, reason: java.io.EOFException, not attempting to automatically reconnect 2013-03-23 11:16:46,527 | ERROR | t-inbound-queue] | faultJmsMessageListenerContainer | AbstractMessageListenerContainer 615 | 104 - org.springframework.jms - 3.0.7.RELEASE | Application exception overridden by rollback exception The content check is true (I can see the log message - Sending $ to reporting queue), but it is failing while sending to reporting queue.

Do I need to do any other config to make the message deliverable to 2 queues?

Thanks for any help in advance

1. Re: Exhausted after delivery attempt: 1 IllegalStateException:Session closed

shenzy_shency.revindran Mar 23, 2013 11:21 AM (in response to shenzy_shency.revindran)

Update:

Noticed that this error happens always but the message reaches the reporting queue in some cases though the error appears in the log. The message was delivered in some cases where the message was marked as persistent message. Note that I am using the send feature provided by activemq console for this testing.

Any help will be appreciated.
Actions
2. Re: Exhausted after delivery attempt: 1 IllegalStateException:Session closed

davsclaus Mar 25, 2013 4:22 AM (in response to shenzy_shency.revindran)

And if you remove the wire tap then you do not see any errors?

And I assume you use ActiveMQ as the message broker? If not what broker do you use?

And what do you do in the wire tap route?
Actions
3. Re: Exhausted after delivery attempt: 1 IllegalStateException:Session closed

davsclaus Mar 25, 2013 4:24 AM (in response to davsclaus)
And how have you configure the jms/activemq component of your Camel application?

eg usually its a
<bean id="activemq" class="..."> // stuff here </bean>

And a bunch of connection factory and other stuff to configure.
Actions
4. Re: Exhausted after delivery attempt: 1 IllegalStateException:Session closed

shenzy_shency.revindran Mar 25, 2013 11:28 AM (in response to davsclaus)

Attached my blueprint.xml for your reference.

I haven't tried without wire tap, I will try that and update.

Edited by: shenzy on Mar 25, 2013 3:28 PM
Actions
5. Re: Exhausted after delivery attempt: 1 IllegalStateException:Session closed

davsclaus Mar 25, 2013 7:27 AM (in response to shenzy_shency.revindran)

Thanks.

On your connection pool you need to add the init / destroy methods, as shown here
http://camel.apache.org/activemq

This ensures the pool is properly started|stopped when your bundle starts|stops.

WireTap uses a different thread than the original route. You could essentially use instead.
Actions
6. Re: Exhausted after delivery attempt: 1 IllegalStateException:Session closed

shenzy_shency.revindran Mar 25, 2013 7:37 AM (in response to davsclaus)

Thanks I will try this
Actions
7. Re: Exhausted after delivery attempt: 1 IllegalStateException:Session closed

shenzy_shency.revindran Mar 25, 2013 8:40 AM (in response to shenzy_shency.revindran)

Tried adding the init and destroy

Outcome:

I am sending non-persistent messages.

First 2 messages did not reach the reporting queue and log showed the same exception

Exhausted after delivery attempt: 1 caught: org.springframework.jms.IllegalStateException: The Session is closed; nested exception is javax.jms.IllegalStateException: The Session is closed

After the second message it started working with out this exception. Working fine till now.

What is going wrong with initial messages?

Could it be something wrong with the messsaging client (the activeMQ web console in my case) ?

Thanks
Actions
8. Re: Exhausted after delivery attempt: 1 IllegalStateException:Session closed

cheekychops_smithcolina Apr 19, 2013 5:38 AM (in response to shenzy_shency.revindran)

By default, PooledConnectionFactory expires connections after 30 seconds. You may want to try setting its idleTimeout to 0 to see if the problem goes away.
Actions

Go to original post