org.springframework.amqp.AmqpException: Unexpected exception on listener execution

[carinelpy]

Hi,

I'm getting the following exception when shutting down the Tomcat server. Any idea on what is causing that error? Thanks.

2011-03-01 10:40:50.0695 ERROR SimpleAsyncTaskExecutor-1 org.springframework.transaction.support.Transactio nTemplate - Application exception overridden by rollback exception
org.springframework.amqp.AmqpException: Unexpected exception on listener execution
at org.springframework.amqp.rabbit.listener.SimpleMes sageListenerContainer$AsyncMessageProcessingConsum er$1.doInTransaction(SimpleMessageListenerContaine r.java:339)
at org.springframework.amqp.rabbit.listener.SimpleMes sageListenerContainer$AsyncMessageProcessingConsum er$1.doInTransaction(SimpleMessageListenerContaine r.java:331)
at org.springframework.transaction.support.Transactio nTemplate.execute(TransactionTemplate.java:130)
at org.springframework.amqp.rabbit.listener.SimpleMes sageListenerContainer$AsyncMessageProcessingConsum er.transactionalReceiveAndExecute(SimpleMessageLis tenerContainer.java:330)
at org.springframework.amqp.rabbit.listener.SimpleMes sageListenerContainer$AsyncMessageProcessingConsum er.run(SimpleMessageListenerContainer.java:305)
at java.lang.Thread.run(Thread.java:680)
Caused by: com.rabbitmq.client.ShutdownSignalException: clean connection shutdown; reason: #method<connection.close>(reply-code=200,reply-text=OK,class-id=0,method-id=0)
at org.springframework.amqp.rabbit.listener.BlockingQ ueueConsumer.handle(BlockingQueueConsumer.java:125 )
at org.springframework.amqp.rabbit.listener.BlockingQ ueueConsumer.nextDelivery(BlockingQueueConsumer.ja va:153)
at org.springframework.amqp.rabbit.listener.SimpleMes sageListenerContainer$AsyncMessageProcessingConsum er.receiveAndExecute(SimpleMessageListenerContaine r.java:369)
at org.springframework.amqp.rabbit.listener.SimpleMes sageListenerContainer$AsyncMessageProcessingConsum er.access$800(SimpleMessageListenerContainer.java: 268)
at org.springframework.amqp.rabbit.listener.SimpleMes sageListenerContainer$AsyncMessageProcessingConsum er$1.doInTransaction(SimpleMessageListenerContaine r.java:334)
... 5 more

[Dave Syer]

A ShutdownException means that your Channel or Connection was closed, which would be normal if the ApplicationContext is shutting down. Up to 1.0.0.M2 you would be quite likely to see this on every shutdown if messages are in flight, which is not ideal. Since then we have tidied it up a bit, so there is a configurable shutdown timeout in the message listener container (default is 10 seconds I think) - it should wait at least that long for in flight messages to finish processing. If you can upgrade to a snapshot (M3 is on the launchpad but not quite ready) you should see different behaviour.

[carinelpy]

Thanks for your reply.