com.rabbitmq.client.ShutdownSignalException: channel error; protocol method: #method<channel.close>(reply-code=406, reply-text=PRECONDITION_FAILED - unknown delivery tag 1, class-id=60, method-id=80)

Spring JIRA | Gary Russell | 1 year ago
  1. 0

    {code} 2015-11-16 08:24:10,271 DEBUG [org.springframework.integration.amqp.channel.ChannelTests] - <!!!! Starting test: testAmqpChannelFactoryBean !!!!> 2015-11-16 08:24:10,275 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:10,276 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{amq.ctag-UtveMu8bVqcxj_Lb6t6x4g=2c29095a-6f21-412e-8167-5dd5cc6dcb16}], channel=Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,1), acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:10,277 DEBUG [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Creating cached Rabbit Channel from AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:10,278 DEBUG [org.springframework.amqp.rabbit.core.RabbitTemplate] - <Executing callback on RabbitMQ Channel: Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:10,279 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Returning cached Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:10,286 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2) retrieved from cache> 2015-11-16 08:24:10,287 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Found cached Rabbit Channel: Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:10,288 DEBUG [org.springframework.amqp.rabbit.core.RabbitTemplate] - <Executing callback on RabbitMQ Channel: Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:10,288 DEBUG [org.springframework.amqp.rabbit.core.RabbitAdmin] - <declaring Exchange 'si.fanout.testChannel'> 2015-11-16 08:24:10,289 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Returning cached Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:10,290 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2) retrieved from cache> 2015-11-16 08:24:10,291 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Found cached Rabbit Channel: Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:10,291 DEBUG [org.springframework.amqp.rabbit.core.RabbitTemplate] - <Executing callback on RabbitMQ Channel: Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:10,291 DEBUG [org.springframework.amqp.rabbit.core.RabbitAdmin] - <declaring Queue '34b15473-3b9b-4173-b58c-c1b85ed341a6'> 2015-11-16 08:24:10,293 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Returning cached Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:10,295 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2) retrieved from cache> 2015-11-16 08:24:10,301 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Found cached Rabbit Channel: Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:10,302 DEBUG [org.springframework.amqp.rabbit.core.RabbitTemplate] - <Executing callback on RabbitMQ Channel: Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:10,304 DEBUG [org.springframework.amqp.rabbit.core.RabbitAdmin] - <Binding destination [34b15473-3b9b-4173-b58c-c1b85ed341a6 (QUEUE)] to exchange [si.fanout.testChannel] with routing key []> 2015-11-16 08:24:10,306 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Returning cached Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:10,306 DEBUG [org.springframework.integration.amqp.channel.ChannelTests] - <!!!! Finished test: testAmqpChannelFactoryBean !!!!> 2015-11-16 08:24:12,982 DEBUG [org.springframework.integration.amqp.channel.ChannelTests] - <!!!! Starting test: pubSubLostConnectionTest !!!!> 2015-11-16 08:24:12,983 DEBUG [org.springframework.integration.amqp.channel.PublishSubscribeAmqpChannel] - <preSend on channel 'foo', message: GenericMessage [payload=foo, headers={id=9c2dfb07-a61e-1533-6fa8-774c569eb4e3, timestamp=1447691052983}]> 2015-11-16 08:24:12,990 DEBUG [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Creating cached Rabbit Channel from AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:12,990 DEBUG [org.springframework.amqp.rabbit.core.RabbitTemplate] - <Executing callback on RabbitMQ Channel: Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:12,991 DEBUG [org.springframework.amqp.rabbit.core.RabbitTemplate] - <Publishing message on exchange [si.fanout.foo], routingKey = []> 2015-11-16 08:24:12,992 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Returning cached Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:12,992 DEBUG [org.springframework.integration.amqp.channel.PublishSubscribeAmqpChannel] - <postSend (sent=true) on channel 'foo', message: GenericMessage [payload=foo, headers={id=9c2dfb07-a61e-1533-6fa8-774c569eb4e3, timestamp=1447691052983}]> 2015-11-16 08:24:12,992 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Storing delivery for Consumer: tags=[{amq.ctag-rMTRv_zuMkvc34DqsHd8zA=3aa6d6dc-c988-41b3-bb9e-99ec7e159e74}], channel=Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,1), acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:12,993 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:12,993 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{amq.ctag-rMTRv_zuMkvc34DqsHd8zA=3aa6d6dc-c988-41b3-bb9e-99ec7e159e74}], channel=Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,1), acknowledgeMode=AUTO local queue size=1> 2015-11-16 08:24:12,999 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Received message: (Body:'GenericMessage [payload=foo, headers={id=9c2dfb07-a61e-1533-6fa8-774c569eb4e3, timestamp=1447691052983}]'MessageProperties [headers={}, timestamp=null, messageId=null, userId=null, appId=null, clusterId=null, type=null, correlationId=null, replyTo=null, contentType=application/x-java-serialized-object, contentEncoding=null, contentLength=0, deliveryMode=PERSISTENT, expiration=null, priority=0, redelivered=false, receivedExchange=si.fanout.foo, receivedRoutingKey=, deliveryTag=1, messageCount=0])> 2015-11-16 08:24:13,001 DEBUG [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Closing cached Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:13,005 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Received shutdown signal for consumer tag=amq.ctag-rMTRv_zuMkvc34DqsHd8zA: clean connection shutdown; protocol method: #method<connection.close>(reply-code=200, reply-text=OK, class-id=0, method-id=0)> 2015-11-16 08:24:13,019 DEBUG [org.springframework.integration.amqp.channel.PublishSubscribeAmqpChannel] - <preSend on channel 'foo', message: GenericMessage [payload=bar, headers={id=0b90388c-3a9d-391e-483c-cec3b39f0d02, timestamp=1447691053019}]> 2015-11-16 08:24:13,073 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:13,074 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{amq.ctag-1QiJjvBUKDAcgRoOY973OQ=si.test.queue}], channel=Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,1), acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:13,120 INFO [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Created new connection: SimpleConnection@7e13d943 [delegate=amqp://guest@127.0.0.1:5672/]> 2015-11-16 08:24:13,123 DEBUG [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Creating cached Rabbit Channel from AMQChannel(amqp://guest@127.0.0.1:5672/,1)> 2015-11-16 08:24:13,123 DEBUG [org.springframework.amqp.rabbit.core.RabbitTemplate] - <Executing callback on RabbitMQ Channel: Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,1)> 2015-11-16 08:24:13,123 DEBUG [org.springframework.amqp.rabbit.core.RabbitAdmin] - <declaring Queue '3aa6d6dc-c988-41b3-bb9e-99ec7e159e74'> 2015-11-16 08:24:13,125 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Returning cached Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,1)> 2015-11-16 08:24:13,126 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,1) retrieved from cache> 2015-11-16 08:24:13,126 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Found cached Rabbit Channel: Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,1)> 2015-11-16 08:24:13,126 DEBUG [org.springframework.amqp.rabbit.core.RabbitTemplate] - <Executing callback on RabbitMQ Channel: Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,1)> 2015-11-16 08:24:13,126 DEBUG [org.springframework.amqp.rabbit.core.RabbitAdmin] - <Binding destination [3aa6d6dc-c988-41b3-bb9e-99ec7e159e74 (QUEUE)] to exchange [si.fanout.foo] with routing key []> 2015-11-16 08:24:13,127 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Returning cached Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,1)> 2015-11-16 08:24:13,127 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,1) retrieved from cache> 2015-11-16 08:24:13,127 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Found cached Rabbit Channel: Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,1)> 2015-11-16 08:24:13,127 DEBUG [org.springframework.amqp.rabbit.core.RabbitTemplate] - <Executing callback on RabbitMQ Channel: Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,1)> 2015-11-16 08:24:13,127 DEBUG [org.springframework.amqp.rabbit.core.RabbitTemplate] - <Publishing message on exchange [si.fanout.foo], routingKey = []> 2015-11-16 08:24:13,130 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Returning cached Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,1)> 2015-11-16 08:24:13,130 DEBUG [org.springframework.integration.amqp.channel.PublishSubscribeAmqpChannel] - <postSend (sent=true) on channel 'foo', message: GenericMessage [payload=bar, headers={id=0b90388c-3a9d-391e-483c-cec3b39f0d02, timestamp=1447691053019}]> 2015-11-16 08:24:13,134 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:13,135 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{amq.ctag-rMTRv_zuMkvc34DqsHd8zA=3aa6d6dc-c988-41b3-bb9e-99ec7e159e74}], channel=Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2), acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:13,138 DEBUG [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Consumer received Shutdown Signal, processing stopped: clean connection shutdown; protocol method: #method<connection.close>(reply-code=200, reply-text=OK, class-id=0, method-id=0)> 2015-11-16 08:24:13,138 INFO [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Restarting Consumer: tags=[{amq.ctag-rMTRv_zuMkvc34DqsHd8zA=3aa6d6dc-c988-41b3-bb9e-99ec7e159e74}], channel=Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2), acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:13,139 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Error closing consumer> org.springframework.amqp.AmqpIOException: java.io.IOException: Unknown consumerTag at org.springframework.amqp.rabbit.support.RabbitExceptionTranslator.convertRabbitAccessException(RabbitExceptionTranslator.java:67) at org.springframework.amqp.rabbit.connection.RabbitUtils.closeMessageConsumer(RabbitUtils.java:138) at org.springframework.amqp.rabbit.listener.BlockingQueueConsumer.stop(BlockingQueueConsumer.java:586) at org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer.restart(SimpleMessageListenerContainer.java:994) at org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer.access$3000(SimpleMessageListenerContainer.java:93) at org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer$AsyncMessageProcessingConsumer.run(SimpleMessageListenerContainer.java:1322) at java.lang.Thread.run(Thread.java:745) Caused by: java.io.IOException: Unknown consumerTag at com.rabbitmq.client.impl.ChannelN.basicCancel(ChannelN.java:1117) at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.lang.reflect.Method.invoke(Method.java:497) at org.springframework.amqp.rabbit.connection.CachingConnectionFactory$CachedChannelInvocationHandler.invoke(CachingConnectionFactory.java:704) at com.sun.proxy.$Proxy28.basicCancel(Unknown Source) at org.springframework.amqp.rabbit.connection.RabbitUtils.closeMessageConsumer(RabbitUtils.java:124) ... 5 more 2015-11-16 08:24:13,141 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Closing Rabbit Channel: Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:13,142 DEBUG [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Closing cached Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:13,334 DEBUG [org.springframework.amqp.rabbit.connection.RabbitUtils] - <Unexpected exception on closing RabbitMQ Channel> com.rabbitmq.client.ShutdownSignalException: channel error; protocol method: #method<channel.close>(reply-code=406, reply-text=PRECONDITION_FAILED - unknown delivery tag 1, class-id=60, method-id=80) at com.rabbitmq.utility.ValueOrException.getValue(ValueOrException.java:67) at com.rabbitmq.utility.BlockingValueOrException.uninterruptibleGetValue(BlockingValueOrException.java:37) at com.rabbitmq.client.impl.AMQChannel$BlockingRpcContinuation.getReply(AMQChannel.java:367) at com.rabbitmq.client.impl.ChannelN.close(ChannelN.java:582) at com.rabbitmq.client.impl.ChannelN.close(ChannelN.java:509) at com.rabbitmq.client.impl.ChannelN.close(ChannelN.java:503) at org.springframework.amqp.rabbit.connection.CachingConnectionFactory$CachedChannelInvocationHandler.physicalClose(CachingConnectionFactory.java:807) at org.springframework.amqp.rabbit.connection.CachingConnectionFactory$CachedChannelInvocationHandler.invoke(CachingConnectionFactory.java:677) at com.sun.proxy.$Proxy28.close(Unknown Source) at org.springframework.amqp.rabbit.connection.RabbitUtils.closeChannel(RabbitUtils.java:80) at org.springframework.amqp.rabbit.connection.ConnectionFactoryUtils.releaseResources(ConnectionFactoryUtils.java:162) at org.springframework.amqp.rabbit.listener.BlockingQueueConsumer.stop(BlockingQueueConsumer.java:599) at org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer.restart(SimpleMessageListenerContainer.java:994) at org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer.access$3000(SimpleMessageListenerContainer.java:93) at org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer$AsyncMessageProcessingConsumer.run(SimpleMessageListenerContainer.java:1322) at java.lang.Thread.run(Thread.java:745) Caused by: com.rabbitmq.client.ShutdownSignalException: channel error; protocol method: #method<channel.close>(reply-code=406, reply-text=PRECONDITION_FAILED - unknown delivery tag 1, class-id=60, method-id=80) at com.rabbitmq.client.impl.ChannelN.asyncShutdown(ChannelN.java:484) at com.rabbitmq.client.impl.ChannelN.processAsync(ChannelN.java:321) at com.rabbitmq.client.impl.AMQChannel.handleCompleteInboundCommand(AMQChannel.java:144) at com.rabbitmq.client.impl.AMQChannel.handleFrame(AMQChannel.java:91) at com.rabbitmq.client.impl.AMQConnection$MainLoop.run(AMQConnection.java:554) ... 1 more 2015-11-16 08:24:13,338 ERROR [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Channel shutdown: connection error> 2015-11-16 08:24:13,446 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Starting consumer Consumer: tags=[{}], channel=null, acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:13,476 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:13,476 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{}], channel=org.springframework.integration.amqp.StubRabbitConnectionFactory$StubChannel@458912c5, acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:13,476 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:13,476 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{}], channel=org.springframework.integration.amqp.StubRabbitConnectionFactory$StubChannel@6809a22, acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:13,478 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:13,479 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{}], channel=org.springframework.integration.amqp.StubRabbitConnectionFactory$StubChannel@42c80fee, acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:13,620 INFO [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Created new connection: SimpleConnection@6c800b8c [delegate=amqp://guest@127.0.0.1:5672/]> 2015-11-16 08:24:13,621 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,1) retrieved from cache> 2015-11-16 08:24:13,621 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,1) is already closed> 2015-11-16 08:24:13,627 DEBUG [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Creating cached Rabbit Channel from AMQChannel(amqp://guest@127.0.0.1:5672/,1)> 2015-11-16 08:24:13,628 DEBUG [org.springframework.amqp.rabbit.core.RabbitTemplate] - <Executing callback on RabbitMQ Channel: Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,1)> 2015-11-16 08:24:13,628 DEBUG [org.springframework.amqp.rabbit.core.RabbitAdmin] - <declaring Queue '3aa6d6dc-c988-41b3-bb9e-99ec7e159e74'> 2015-11-16 08:24:13,631 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Returning cached Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,1)> 2015-11-16 08:24:13,631 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,1) retrieved from cache> 2015-11-16 08:24:13,631 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Found cached Rabbit Channel: Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,1)> 2015-11-16 08:24:13,631 DEBUG [org.springframework.amqp.rabbit.core.RabbitTemplate] - <Executing callback on RabbitMQ Channel: Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,1)> 2015-11-16 08:24:13,631 DEBUG [org.springframework.amqp.rabbit.core.RabbitAdmin] - <Binding destination [3aa6d6dc-c988-41b3-bb9e-99ec7e159e74 (QUEUE)] to exchange [si.fanout.foo] with routing key []> 2015-11-16 08:24:13,633 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Returning cached Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,1)> 2015-11-16 08:24:13,635 DEBUG [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Creating cached Rabbit Channel from AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:13,637 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Started on queue '3aa6d6dc-c988-41b3-bb9e-99ec7e159e74' with tag amq.ctag-0MV-aPvceyTeBSFyc-h1Bg: Consumer: tags=[{amq.ctag-0MV-aPvceyTeBSFyc-h1Bg=3aa6d6dc-c988-41b3-bb9e-99ec7e159e74}], channel=Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2), acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:13,637 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:13,637 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{amq.ctag-0MV-aPvceyTeBSFyc-h1Bg=3aa6d6dc-c988-41b3-bb9e-99ec7e159e74}], channel=Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2), acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:13,638 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <ConsumeOK : Consumer: tags=[{amq.ctag-0MV-aPvceyTeBSFyc-h1Bg=3aa6d6dc-c988-41b3-bb9e-99ec7e159e74}], channel=Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2), acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:14,075 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:14,075 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{amq.ctag-1QiJjvBUKDAcgRoOY973OQ=si.test.queue}], channel=Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,1), acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:14,270 WARN [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Consumer raised exception, processing can restart if the connection factory supports it> java.lang.IllegalArgumentException: Connection must not be null at org.springframework.util.Assert.notNull(Assert.java:115) at org.springframework.amqp.rabbit.connection.RabbitResourceHolder.addConnection(RabbitResourceHolder.java:101) at org.springframework.amqp.rabbit.connection.ConnectionFactoryUtils.doGetTransactionalResourceHolder(ConnectionFactoryUtils.java:136) at org.springframework.amqp.rabbit.connection.ConnectionFactoryUtils.getTransactionalResourceHolder(ConnectionFactoryUtils.java:71) at org.springframework.amqp.rabbit.listener.BlockingQueueConsumer.start(BlockingQueueConsumer.java:456) at org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer$AsyncMessageProcessingConsumer.run(SimpleMessageListenerContainer.java:1165) at java.lang.Thread.run(Thread.java:745) 2015-11-16 08:24:14,271 INFO [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Restarting Consumer: tags=[{}], channel=null, acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:14,271 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Closing Rabbit Channel: null> 2015-11-16 08:24:14,288 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Starting consumer Consumer: tags=[{}], channel=null, acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:14,290 DEBUG [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Recovering consumer in 5000 ms.> 2015-11-16 08:24:14,478 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:14,479 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{}], channel=org.springframework.integration.amqp.StubRabbitConnectionFactory$StubChannel@458912c5, acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:14,479 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:14,479 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{}], channel=org.springframework.integration.amqp.StubRabbitConnectionFactory$StubChannel@6809a22, acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:14,481 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:14,481 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{}], channel=org.springframework.integration.amqp.StubRabbitConnectionFactory$StubChannel@42c80fee, acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:14,640 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:14,640 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{amq.ctag-0MV-aPvceyTeBSFyc-h1Bg=3aa6d6dc-c988-41b3-bb9e-99ec7e159e74}], channel=Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2), acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:14,876 WARN [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Consumer raised exception, processing can restart if the connection factory supports it> java.lang.IllegalArgumentException: Connection must not be null at org.springframework.util.Assert.notNull(Assert.java:115) at org.springframework.amqp.rabbit.connection.RabbitResourceHolder.addConnection(RabbitResourceHolder.java:101) at org.springframework.amqp.rabbit.connection.ConnectionFactoryUtils.doGetTransactionalResourceHolder(ConnectionFactoryUtils.java:136) at org.springframework.amqp.rabbit.connection.ConnectionFactoryUtils.getTransactionalResourceHolder(ConnectionFactoryUtils.java:71) at org.springframework.amqp.rabbit.listener.BlockingQueueConsumer.start(BlockingQueueConsumer.java:456) at org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer$AsyncMessageProcessingConsumer.run(SimpleMessageListenerContainer.java:1165) at java.lang.Thread.run(Thread.java:745) 2015-11-16 08:24:14,876 INFO [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Restarting Consumer: tags=[{}], channel=null, acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:14,876 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Closing Rabbit Channel: null> 2015-11-16 08:24:14,883 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Starting consumer Consumer: tags=[{}], channel=null, acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:14,886 DEBUG [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Recovering consumer in 5000 ms.> 2015-11-16 08:24:15,089 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:15,090 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{amq.ctag-1QiJjvBUKDAcgRoOY973OQ=si.test.queue}], channel=Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,1), acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:15,480 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:15,480 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{}], channel=org.springframework.integration.amqp.StubRabbitConnectionFactory$StubChannel@458912c5, acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:15,481 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:15,481 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{}], channel=org.springframework.integration.amqp.StubRabbitConnectionFactory$StubChannel@6809a22, acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:15,483 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:15,483 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{}], channel=org.springframework.integration.amqp.StubRabbitConnectionFactory$StubChannel@42c80fee, acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:15,641 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:15,642 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{amq.ctag-0MV-aPvceyTeBSFyc-h1Bg=3aa6d6dc-c988-41b3-bb9e-99ec7e159e74}], channel=Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2), acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:16,091 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:16,091 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{amq.ctag-1QiJjvBUKDAcgRoOY973OQ=si.test.queue}], channel=Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,1), acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:16,485 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:16,486 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{}], channel=org.springframework.integration.amqp.StubRabbitConnectionFactory$StubChannel@42c80fee, acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:16,492 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:16,492 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{}], channel=org.springframework.integration.amqp.StubRabbitConnectionFactory$StubChannel@458912c5, acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:16,493 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:16,493 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{}], channel=org.springframework.integration.amqp.StubRabbitConnectionFactory$StubChannel@6809a22, acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:16,644 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:16,644 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{amq.ctag-0MV-aPvceyTeBSFyc-h1Bg=3aa6d6dc-c988-41b3-bb9e-99ec7e159e74}], channel=Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2), acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:17,093 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:17,093 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{amq.ctag-1QiJjvBUKDAcgRoOY973OQ=si.test.queue}], channel=Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,1), acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:17,487 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:17,487 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{}], channel=org.springframework.integration.amqp.StubRabbitConnectionFactory$StubChannel@42c80fee, acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:17,493 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:17,493 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{}], channel=org.springframework.integration.amqp.StubRabbitConnectionFactory$StubChannel@458912c5, acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:17,493 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:17,494 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{}], channel=org.springframework.integration.amqp.StubRabbitConnectionFactory$StubChannel@6809a22, acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:17,647 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:17,647 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{amq.ctag-0MV-aPvceyTeBSFyc-h1Bg=3aa6d6dc-c988-41b3-bb9e-99ec7e159e74}], channel=Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2), acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:18,095 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:18,096 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{amq.ctag-1QiJjvBUKDAcgRoOY973OQ=si.test.queue}], channel=Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,1), acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:18,490 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:18,490 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{}], channel=org.springframework.integration.amqp.StubRabbitConnectionFactory$StubChannel@42c80fee, acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:18,496 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:18,496 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{}], channel=org.springframework.integration.amqp.StubRabbitConnectionFactory$StubChannel@458912c5, acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:18,496 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:18,496 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{}], channel=org.springframework.integration.amqp.StubRabbitConnectionFactory$StubChannel@6809a22, acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:18,648 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:18,648 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{amq.ctag-0MV-aPvceyTeBSFyc-h1Bg=3aa6d6dc-c988-41b3-bb9e-99ec7e159e74}], channel=Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2), acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:19,097 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:19,097 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{amq.ctag-1QiJjvBUKDAcgRoOY973OQ=si.test.queue}], channel=Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,1), acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:19,435 WARN [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Consumer raised exception, processing can restart if the connection factory supports it> java.lang.IllegalArgumentException: Connection must not be null at org.springframework.util.Assert.notNull(Assert.java:115) at org.springframework.amqp.rabbit.connection.RabbitResourceHolder.addConnection(RabbitResourceHolder.java:101) at org.springframework.amqp.rabbit.connection.ConnectionFactoryUtils.doGetTransactionalResourceHolder(ConnectionFactoryUtils.java:136) at org.springframework.amqp.rabbit.connection.ConnectionFactoryUtils.getTransactionalResourceHolder(ConnectionFactoryUtils.java:71) at org.springframework.amqp.rabbit.listener.BlockingQueueConsumer.start(BlockingQueueConsumer.java:456) at org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer$AsyncMessageProcessingConsumer.run(SimpleMessageListenerContainer.java:1165) at java.lang.Thread.run(Thread.java:745) 2015-11-16 08:24:19,435 INFO [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Restarting Consumer: tags=[{}], channel=null, acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:19,435 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Closing Rabbit Channel: null> 2015-11-16 08:24:19,466 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Starting consumer Consumer: tags=[{}], channel=null, acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:19,468 DEBUG [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Recovering consumer in 5000 ms.> 2015-11-16 08:24:19,492 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:19,492 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{}], channel=org.springframework.integration.amqp.StubRabbitConnectionFactory$StubChannel@42c80fee, acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:19,499 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:19,500 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{}], channel=org.springframework.integration.amqp.StubRabbitConnectionFactory$StubChannel@458912c5, acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:19,500 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:19,500 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{}], channel=org.springframework.integration.amqp.StubRabbitConnectionFactory$StubChannel@6809a22, acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:19,651 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:19,651 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{amq.ctag-0MV-aPvceyTeBSFyc-h1Bg=3aa6d6dc-c988-41b3-bb9e-99ec7e159e74}], channel=Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2), acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:20,042 WARN [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Consumer raised exception, processing can restart if the connection factory supports it> java.lang.IllegalArgumentException: Connection must not be null at org.springframework.util.Assert.notNull(Assert.java:115) at org.springframework.amqp.rabbit.connection.RabbitResourceHolder.addConnection(RabbitResourceHolder.java:101) at org.springframework.amqp.rabbit.connection.ConnectionFactoryUtils.doGetTransactionalResourceHolder(ConnectionFactoryUtils.java:136) at org.springframework.amqp.rabbit.connection.ConnectionFactoryUtils.getTransactionalResourceHolder(ConnectionFactoryUtils.java:71) at org.springframework.amqp.rabbit.listener.BlockingQueueConsumer.start(BlockingQueueConsumer.java:456) at org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer$AsyncMessageProcessingConsumer.run(SimpleMessageListenerContainer.java:1165) at java.lang.Thread.run(Thread.java:745) 2015-11-16 08:24:20,042 INFO [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Restarting Consumer: tags=[{}], channel=null, acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:20,042 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Closing Rabbit Channel: null> 2015-11-16 08:24:20,045 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Starting consumer Consumer: tags=[{}], channel=null, acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:20,046 DEBUG [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Recovering consumer in 5000 ms.> 2015-11-16 08:24:20,102 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:20,103 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{amq.ctag-1QiJjvBUKDAcgRoOY973OQ=si.test.queue}], channel=Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,1), acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:20,495 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:20,495 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{}], channel=org.springframework.integration.amqp.StubRabbitConnectionFactory$StubChannel@42c80fee, acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:20,502 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:20,502 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{}], channel=org.springframework.integration.amqp.StubRabbitConnectionFactory$StubChannel@458912c5, acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:20,502 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:20,502 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{}], channel=org.springframework.integration.amqp.StubRabbitConnectionFactory$StubChannel@6809a22, acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:20,671 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:20,671 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{amq.ctag-0MV-aPvceyTeBSFyc-h1Bg=3aa6d6dc-c988-41b3-bb9e-99ec7e159e74}], channel=Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2), acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:21,104 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:21,104 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{amq.ctag-1QiJjvBUKDAcgRoOY973OQ=si.test.queue}], channel=Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,1), acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:21,496 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:21,496 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{}], channel=org.springframework.integration.amqp.StubRabbitConnectionFactory$StubChannel@42c80fee, acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:21,525 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:21,525 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{}], channel=org.springframework.integration.amqp.StubRabbitConnectionFactory$StubChannel@458912c5, acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:21,525 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:21,526 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{}], channel=org.springframework.integration.amqp.StubRabbitConnectionFactory$StubChannel@6809a22, acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:21,673 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:21,673 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{amq.ctag-0MV-aPvceyTeBSFyc-h1Bg=3aa6d6dc-c988-41b3-bb9e-99ec7e159e74}], channel=Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2), acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:22,106 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:22,106 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{amq.ctag-1QiJjvBUKDAcgRoOY973OQ=si.test.queue}], channel=Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,1), acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:22,498 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:22,498 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{}], channel=org.springframework.integration.amqp.StubRabbitConnectionFactory$StubChannel@42c80fee, acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:22,527 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:22,527 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{}], channel=org.springframework.integration.amqp.StubRabbitConnectionFactory$StubChannel@458912c5, acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:22,527 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:22,527 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{}], channel=org.springframework.integration.amqp.StubRabbitConnectionFactory$StubChannel@6809a22, acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:22,676 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:22,676 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{amq.ctag-0MV-aPvceyTeBSFyc-h1Bg=3aa6d6dc-c988-41b3-bb9e-99ec7e159e74}], channel=Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2), acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:23,107 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:23,108 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{amq.ctag-1QiJjvBUKDAcgRoOY973OQ=si.test.queue}], channel=Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,1), acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:23,132 DEBUG [org.springframework.integration.amqp.channel.ChannelTests] - <!!!! Finished test: pubSubLostConnectionTest !!!!> 2015-11-16 08:24:24,567 WARN [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Consumer raised exception, processing can restart if the connection factory supports it> java.lang.IllegalArgumentException: Connection must not be null at org.springframework.util.Assert.notNull(Assert.java:115) at org.springframework.amqp.rabbit.connection.RabbitResourceHolder.addConnection(RabbitResourceHolder.java:101) at org.springframework.amqp.rabbit.connection.ConnectionFactoryUtils.doGetTransactionalResourceHolder(ConnectionFactoryUtils.java:136) at org.springframework.amqp.rabbit.connection.ConnectionFactoryUtils.getTransactionalResourceHolder(ConnectionFactoryUtils.java:71) at org.springframework.amqp.rabbit.listener.BlockingQueueConsumer.start(BlockingQueueConsumer.java:456) at org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer$AsyncMessageProcessingConsumer.run(SimpleMessageListenerContainer.java:1165) at java.lang.Thread.run(Thread.java:745) 2015-11-16 08:24:24,679 DEBUG [org.springframework.integration.amqp.channel.ChannelTests] - <!!!! Starting test: channelDeclarationTests !!!!> 2015-11-16 08:24:24,680 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:24,680 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{amq.ctag-WiUzQGIVjjQPzsjvtNwkmQ=a92d4b20-b227-4aea-8801-67ba92dabdc5}], channel=Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,1), acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:24,682 DEBUG [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Creating cached Rabbit Channel from AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:24,683 DEBUG [org.springframework.amqp.rabbit.core.RabbitTemplate] - <Executing callback on RabbitMQ Channel: Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:24,686 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Returning cached Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:24,687 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2) retrieved from cache> 2015-11-16 08:24:24,687 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Found cached Rabbit Channel: Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:24,687 DEBUG [org.springframework.amqp.rabbit.core.RabbitTemplate] - <Executing callback on RabbitMQ Channel: Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:24,688 DEBUG [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Channel shutdown: channel error; protocol method: #method<channel.close>(reply-code=404, reply-text=NOT_FOUND - no queue 'implicit' in vhost '/', class-id=50, method-id=10)> 2015-11-16 08:24:24,690 DEBUG [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Detected closed channel on exception. Re-initializing: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:24,718 DEBUG [org.springframework.amqp.rabbit.core.RabbitAdmin] - <Queue 'implicit' does not exist> 2015-11-16 08:24:24,718 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Returning cached Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:24,718 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2) retrieved from cache> 2015-11-16 08:24:24,718 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Found cached Rabbit Channel: Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:24,718 DEBUG [org.springframework.amqp.rabbit.core.RabbitTemplate] - <Executing callback on RabbitMQ Channel: Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:24,719 DEBUG [org.springframework.amqp.rabbit.core.RabbitAdmin] - <declaring Queue 'implicit'> 2015-11-16 08:24:24,925 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Returning cached Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:24,926 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2) retrieved from cache> 2015-11-16 08:24:24,926 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Found cached Rabbit Channel: Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:24,926 DEBUG [org.springframework.amqp.rabbit.core.RabbitTemplate] - <Executing callback on RabbitMQ Channel: Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:24,926 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Returning cached Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:24,926 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2) retrieved from cache> 2015-11-16 08:24:24,926 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Found cached Rabbit Channel: Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:24,926 DEBUG [org.springframework.amqp.rabbit.core.RabbitTemplate] - <Executing callback on RabbitMQ Channel: Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:25,107 WARN [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Consumer raised exception, processing can restart if the connection factory supports it> java.lang.IllegalArgumentException: Connection must not be null at org.springframework.util.Assert.notNull(Assert.java:115) at org.springframework.amqp.rabbit.connection.RabbitResourceHolder.addConnection(RabbitResourceHolder.java:101) at org.springframework.amqp.rabbit.connection.ConnectionFactoryUtils.doGetTransactionalResourceHolder(ConnectionFactoryUtils.java:136) at org.springframework.amqp.rabbit.connection.ConnectionFactoryUtils.getTransactionalResourceHolder(ConnectionFactoryUtils.java:71) at org.springframework.amqp.rabbit.listener.BlockingQueueConsumer.start(BlockingQueueConsumer.java:456) at org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer$AsyncMessageProcessingConsumer.run(SimpleMessageListenerContainer.java:1165) at java.lang.Thread.run(Thread.java:745) 2015-11-16 08:24:25,107 INFO [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Restarting Consumer: tags=[{}], channel=null, acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:25,107 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Closing Rabbit Channel: null> 2015-11-16 08:24:25,193 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:25,193 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{amq.ctag-1QiJjvBUKDAcgRoOY973OQ=si.test.queue}], channel=Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,1), acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:25,193 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Starting consumer Consumer: tags=[{}], channel=null, acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:25,199 DEBUG [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Recovering consumer in 5000 ms.> 2015-11-16 08:24:25,318 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Returning cached Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:25,318 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2) retrieved from cache> 2015-11-16 08:24:25,318 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Found cached Rabbit Channel: Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:25,318 DEBUG [org.springframework.amqp.rabbit.core.RabbitTemplate] - <Executing callback on RabbitMQ Channel: Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:25,326 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Returning cached Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:25,326 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2) retrieved from cache> 2015-11-16 08:24:25,326 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Found cached Rabbit Channel: Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:25,326 DEBUG [org.springframework.amqp.rabbit.core.RabbitTemplate] - <Executing callback on RabbitMQ Channel: Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:25,349 DEBUG [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Channel shutdown: channel error; protocol method: #method<channel.close>(reply-code=404, reply-text=NOT_FOUND - no queue 'explicit' in vhost '/', class-id=50, method-id=10)> 2015-11-16 08:24:25,349 DEBUG [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Detected closed channel on exception. Re-initializing: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:25,360 DEBUG [org.springframework.amqp.rabbit.core.RabbitAdmin] - <Queue 'explicit' does not exist> 2015-11-16 08:24:25,361 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Returning cached Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:25,361 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2) retrieved from cache> 2015-11-16 08:24:25,361 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Found cached Rabbit Channel: Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:25,361 DEBUG [org.springframework.amqp.rabbit.core.RabbitTemplate] - <Executing callback on RabbitMQ Channel: Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:25,361 DEBUG [org.springframework.amqp.rabbit.core.RabbitAdmin] - <declaring Queue 'explicit'> 2015-11-16 08:24:25,381 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Returning cached Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:25,382 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2) retrieved from cache> 2015-11-16 08:24:25,382 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Found cached Rabbit Channel: Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:25,382 DEBUG [org.springframework.amqp.rabbit.core.RabbitTemplate] - <Executing callback on RabbitMQ Channel: Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:25,384 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Returning cached Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:25,384 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2) retrieved from cache> 2015-11-16 08:24:25,384 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Found cached Rabbit Channel: Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:25,384 DEBUG [org.springframework.amqp.rabbit.core.RabbitTemplate] - <Executing callback on RabbitMQ Channel: Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:25,505 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:25,505 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{}], channel=org.springframework.integration.amqp.StubRabbitConnectionFactory$StubChannel@42c80fee, acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:25,532 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:25,532 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{}], channel=org.springframework.integration.amqp.StubRabbitConnectionFactory$StubChannel@458912c5, acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:25,559 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:25,559 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{}], channel=org.springframework.integration.amqp.StubRabbitConnectionFactory$StubChannel@6809a22, acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:25,682 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:25,682 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{amq.ctag-WiUzQGIVjjQPzsjvtNwkmQ=a92d4b20-b227-4aea-8801-67ba92dabdc5}], channel=Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,1), acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:26,196 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:26,196 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{amq.ctag-1QiJjvBUKDAcgRoOY973OQ=si.test.queue}], channel=Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,1), acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:26,243 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Returning cached Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:26,243 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2) retrieved from cache> 2015-11-16 08:24:26,243 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Found cached Rabbit Channel: Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:26,244 DEBUG [org.springframework.amqp.rabbit.core.RabbitTemplate] - <Executing callback on RabbitMQ Channel: Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:26,244 DEBUG [org.springframework.amqp.rabbit.core.RabbitAdmin] - <declaring Queue 'explicit'> 2015-11-16 08:24:26,247 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Returning cached Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:26,247 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2) retrieved from cache> 2015-11-16 08:24:26,247 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Found cached Rabbit Channel: Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:26,247 DEBUG [org.springframework.amqp.rabbit.core.RabbitTemplate] - <Executing callback on RabbitMQ Channel: Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:26,249 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Returning cached Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:26,249 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2) retrieved from cache> 2015-11-16 08:24:26,249 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Found cached Rabbit Channel: Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:26,249 DEBUG [org.springframework.amqp.rabbit.core.RabbitTemplate] - <Executing callback on RabbitMQ Channel: Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:26,279 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Returning cached Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:26,279 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2) retrieved from cache> 2015-11-16 08:24:26,279 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Found cached Rabbit Channel: Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:26,280 DEBUG [org.springframework.amqp.rabbit.core.RabbitTemplate] - <Executing callback on RabbitMQ Channel: Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:26,429 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Returning cached Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:26,430 DEBUG [org.springframework.integration.amqp.channel.ChannelTests] - <!!!! Finished test: channelDeclarationTests !!!!> {code}

    Spring JIRA | 1 year ago | Gary Russell
    com.rabbitmq.client.ShutdownSignalException: channel error; protocol method: #method<channel.close>(reply-code=406, reply-text=PRECONDITION_FAILED - unknown delivery tag 1, class-id=60, method-id=80)
  2. 0

    {code} 2015-11-16 08:24:10,271 DEBUG [org.springframework.integration.amqp.channel.ChannelTests] - <!!!! Starting test: testAmqpChannelFactoryBean !!!!> 2015-11-16 08:24:10,275 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:10,276 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{amq.ctag-UtveMu8bVqcxj_Lb6t6x4g=2c29095a-6f21-412e-8167-5dd5cc6dcb16}], channel=Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,1), acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:10,277 DEBUG [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Creating cached Rabbit Channel from AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:10,278 DEBUG [org.springframework.amqp.rabbit.core.RabbitTemplate] - <Executing callback on RabbitMQ Channel: Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:10,279 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Returning cached Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:10,286 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2) retrieved from cache> 2015-11-16 08:24:10,287 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Found cached Rabbit Channel: Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:10,288 DEBUG [org.springframework.amqp.rabbit.core.RabbitTemplate] - <Executing callback on RabbitMQ Channel: Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:10,288 DEBUG [org.springframework.amqp.rabbit.core.RabbitAdmin] - <declaring Exchange 'si.fanout.testChannel'> 2015-11-16 08:24:10,289 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Returning cached Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:10,290 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2) retrieved from cache> 2015-11-16 08:24:10,291 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Found cached Rabbit Channel: Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:10,291 DEBUG [org.springframework.amqp.rabbit.core.RabbitTemplate] - <Executing callback on RabbitMQ Channel: Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:10,291 DEBUG [org.springframework.amqp.rabbit.core.RabbitAdmin] - <declaring Queue '34b15473-3b9b-4173-b58c-c1b85ed341a6'> 2015-11-16 08:24:10,293 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Returning cached Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:10,295 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2) retrieved from cache> 2015-11-16 08:24:10,301 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Found cached Rabbit Channel: Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:10,302 DEBUG [org.springframework.amqp.rabbit.core.RabbitTemplate] - <Executing callback on RabbitMQ Channel: Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:10,304 DEBUG [org.springframework.amqp.rabbit.core.RabbitAdmin] - <Binding destination [34b15473-3b9b-4173-b58c-c1b85ed341a6 (QUEUE)] to exchange [si.fanout.testChannel] with routing key []> 2015-11-16 08:24:10,306 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Returning cached Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:10,306 DEBUG [org.springframework.integration.amqp.channel.ChannelTests] - <!!!! Finished test: testAmqpChannelFactoryBean !!!!> 2015-11-16 08:24:12,982 DEBUG [org.springframework.integration.amqp.channel.ChannelTests] - <!!!! Starting test: pubSubLostConnectionTest !!!!> 2015-11-16 08:24:12,983 DEBUG [org.springframework.integration.amqp.channel.PublishSubscribeAmqpChannel] - <preSend on channel 'foo', message: GenericMessage [payload=foo, headers={id=9c2dfb07-a61e-1533-6fa8-774c569eb4e3, timestamp=1447691052983}]> 2015-11-16 08:24:12,990 DEBUG [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Creating cached Rabbit Channel from AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:12,990 DEBUG [org.springframework.amqp.rabbit.core.RabbitTemplate] - <Executing callback on RabbitMQ Channel: Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:12,991 DEBUG [org.springframework.amqp.rabbit.core.RabbitTemplate] - <Publishing message on exchange [si.fanout.foo], routingKey = []> 2015-11-16 08:24:12,992 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Returning cached Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:12,992 DEBUG [org.springframework.integration.amqp.channel.PublishSubscribeAmqpChannel] - <postSend (sent=true) on channel 'foo', message: GenericMessage [payload=foo, headers={id=9c2dfb07-a61e-1533-6fa8-774c569eb4e3, timestamp=1447691052983}]> 2015-11-16 08:24:12,992 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Storing delivery for Consumer: tags=[{amq.ctag-rMTRv_zuMkvc34DqsHd8zA=3aa6d6dc-c988-41b3-bb9e-99ec7e159e74}], channel=Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,1), acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:12,993 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:12,993 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{amq.ctag-rMTRv_zuMkvc34DqsHd8zA=3aa6d6dc-c988-41b3-bb9e-99ec7e159e74}], channel=Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,1), acknowledgeMode=AUTO local queue size=1> 2015-11-16 08:24:12,999 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Received message: (Body:'GenericMessage [payload=foo, headers={id=9c2dfb07-a61e-1533-6fa8-774c569eb4e3, timestamp=1447691052983}]'MessageProperties [headers={}, timestamp=null, messageId=null, userId=null, appId=null, clusterId=null, type=null, correlationId=null, replyTo=null, contentType=application/x-java-serialized-object, contentEncoding=null, contentLength=0, deliveryMode=PERSISTENT, expiration=null, priority=0, redelivered=false, receivedExchange=si.fanout.foo, receivedRoutingKey=, deliveryTag=1, messageCount=0])> 2015-11-16 08:24:13,001 DEBUG [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Closing cached Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:13,005 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Received shutdown signal for consumer tag=amq.ctag-rMTRv_zuMkvc34DqsHd8zA: clean connection shutdown; protocol method: #method<connection.close>(reply-code=200, reply-text=OK, class-id=0, method-id=0)> 2015-11-16 08:24:13,019 DEBUG [org.springframework.integration.amqp.channel.PublishSubscribeAmqpChannel] - <preSend on channel 'foo', message: GenericMessage [payload=bar, headers={id=0b90388c-3a9d-391e-483c-cec3b39f0d02, timestamp=1447691053019}]> 2015-11-16 08:24:13,073 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:13,074 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{amq.ctag-1QiJjvBUKDAcgRoOY973OQ=si.test.queue}], channel=Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,1), acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:13,120 INFO [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Created new connection: SimpleConnection@7e13d943 [delegate=amqp://guest@127.0.0.1:5672/]> 2015-11-16 08:24:13,123 DEBUG [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Creating cached Rabbit Channel from AMQChannel(amqp://guest@127.0.0.1:5672/,1)> 2015-11-16 08:24:13,123 DEBUG [org.springframework.amqp.rabbit.core.RabbitTemplate] - <Executing callback on RabbitMQ Channel: Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,1)> 2015-11-16 08:24:13,123 DEBUG [org.springframework.amqp.rabbit.core.RabbitAdmin] - <declaring Queue '3aa6d6dc-c988-41b3-bb9e-99ec7e159e74'> 2015-11-16 08:24:13,125 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Returning cached Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,1)> 2015-11-16 08:24:13,126 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,1) retrieved from cache> 2015-11-16 08:24:13,126 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Found cached Rabbit Channel: Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,1)> 2015-11-16 08:24:13,126 DEBUG [org.springframework.amqp.rabbit.core.RabbitTemplate] - <Executing callback on RabbitMQ Channel: Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,1)> 2015-11-16 08:24:13,126 DEBUG [org.springframework.amqp.rabbit.core.RabbitAdmin] - <Binding destination [3aa6d6dc-c988-41b3-bb9e-99ec7e159e74 (QUEUE)] to exchange [si.fanout.foo] with routing key []> 2015-11-16 08:24:13,127 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Returning cached Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,1)> 2015-11-16 08:24:13,127 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,1) retrieved from cache> 2015-11-16 08:24:13,127 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Found cached Rabbit Channel: Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,1)> 2015-11-16 08:24:13,127 DEBUG [org.springframework.amqp.rabbit.core.RabbitTemplate] - <Executing callback on RabbitMQ Channel: Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,1)> 2015-11-16 08:24:13,127 DEBUG [org.springframework.amqp.rabbit.core.RabbitTemplate] - <Publishing message on exchange [si.fanout.foo], routingKey = []> 2015-11-16 08:24:13,130 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Returning cached Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,1)> 2015-11-16 08:24:13,130 DEBUG [org.springframework.integration.amqp.channel.PublishSubscribeAmqpChannel] - <postSend (sent=true) on channel 'foo', message: GenericMessage [payload=bar, headers={id=0b90388c-3a9d-391e-483c-cec3b39f0d02, timestamp=1447691053019}]> 2015-11-16 08:24:13,134 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:13,135 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{amq.ctag-rMTRv_zuMkvc34DqsHd8zA=3aa6d6dc-c988-41b3-bb9e-99ec7e159e74}], channel=Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2), acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:13,138 DEBUG [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Consumer received Shutdown Signal, processing stopped: clean connection shutdown; protocol method: #method<connection.close>(reply-code=200, reply-text=OK, class-id=0, method-id=0)> 2015-11-16 08:24:13,138 INFO [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Restarting Consumer: tags=[{amq.ctag-rMTRv_zuMkvc34DqsHd8zA=3aa6d6dc-c988-41b3-bb9e-99ec7e159e74}], channel=Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2), acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:13,139 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Error closing consumer> org.springframework.amqp.AmqpIOException: java.io.IOException: Unknown consumerTag at org.springframework.amqp.rabbit.support.RabbitExceptionTranslator.convertRabbitAccessException(RabbitExceptionTranslator.java:67) at org.springframework.amqp.rabbit.connection.RabbitUtils.closeMessageConsumer(RabbitUtils.java:138) at org.springframework.amqp.rabbit.listener.BlockingQueueConsumer.stop(BlockingQueueConsumer.java:586) at org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer.restart(SimpleMessageListenerContainer.java:994) at org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer.access$3000(SimpleMessageListenerContainer.java:93) at org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer$AsyncMessageProcessingConsumer.run(SimpleMessageListenerContainer.java:1322) at java.lang.Thread.run(Thread.java:745) Caused by: java.io.IOException: Unknown consumerTag at com.rabbitmq.client.impl.ChannelN.basicCancel(ChannelN.java:1117) at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.lang.reflect.Method.invoke(Method.java:497) at org.springframework.amqp.rabbit.connection.CachingConnectionFactory$CachedChannelInvocationHandler.invoke(CachingConnectionFactory.java:704) at com.sun.proxy.$Proxy28.basicCancel(Unknown Source) at org.springframework.amqp.rabbit.connection.RabbitUtils.closeMessageConsumer(RabbitUtils.java:124) ... 5 more 2015-11-16 08:24:13,141 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Closing Rabbit Channel: Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:13,142 DEBUG [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Closing cached Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:13,334 DEBUG [org.springframework.amqp.rabbit.connection.RabbitUtils] - <Unexpected exception on closing RabbitMQ Channel> com.rabbitmq.client.ShutdownSignalException: channel error; protocol method: #method<channel.close>(reply-code=406, reply-text=PRECONDITION_FAILED - unknown delivery tag 1, class-id=60, method-id=80) at com.rabbitmq.utility.ValueOrException.getValue(ValueOrException.java:67) at com.rabbitmq.utility.BlockingValueOrException.uninterruptibleGetValue(BlockingValueOrException.java:37) at com.rabbitmq.client.impl.AMQChannel$BlockingRpcContinuation.getReply(AMQChannel.java:367) at com.rabbitmq.client.impl.ChannelN.close(ChannelN.java:582) at com.rabbitmq.client.impl.ChannelN.close(ChannelN.java:509) at com.rabbitmq.client.impl.ChannelN.close(ChannelN.java:503) at org.springframework.amqp.rabbit.connection.CachingConnectionFactory$CachedChannelInvocationHandler.physicalClose(CachingConnectionFactory.java:807) at org.springframework.amqp.rabbit.connection.CachingConnectionFactory$CachedChannelInvocationHandler.invoke(CachingConnectionFactory.java:677) at com.sun.proxy.$Proxy28.close(Unknown Source) at org.springframework.amqp.rabbit.connection.RabbitUtils.closeChannel(RabbitUtils.java:80) at org.springframework.amqp.rabbit.connection.ConnectionFactoryUtils.releaseResources(ConnectionFactoryUtils.java:162) at org.springframework.amqp.rabbit.listener.BlockingQueueConsumer.stop(BlockingQueueConsumer.java:599) at org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer.restart(SimpleMessageListenerContainer.java:994) at org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer.access$3000(SimpleMessageListenerContainer.java:93) at org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer$AsyncMessageProcessingConsumer.run(SimpleMessageListenerContainer.java:1322) at java.lang.Thread.run(Thread.java:745) Caused by: com.rabbitmq.client.ShutdownSignalException: channel error; protocol method: #method<channel.close>(reply-code=406, reply-text=PRECONDITION_FAILED - unknown delivery tag 1, class-id=60, method-id=80) at com.rabbitmq.client.impl.ChannelN.asyncShutdown(ChannelN.java:484) at com.rabbitmq.client.impl.ChannelN.processAsync(ChannelN.java:321) at com.rabbitmq.client.impl.AMQChannel.handleCompleteInboundCommand(AMQChannel.java:144) at com.rabbitmq.client.impl.AMQChannel.handleFrame(AMQChannel.java:91) at com.rabbitmq.client.impl.AMQConnection$MainLoop.run(AMQConnection.java:554) ... 1 more 2015-11-16 08:24:13,338 ERROR [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Channel shutdown: connection error> 2015-11-16 08:24:13,446 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Starting consumer Consumer: tags=[{}], channel=null, acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:13,476 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:13,476 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{}], channel=org.springframework.integration.amqp.StubRabbitConnectionFactory$StubChannel@458912c5, acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:13,476 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:13,476 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{}], channel=org.springframework.integration.amqp.StubRabbitConnectionFactory$StubChannel@6809a22, acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:13,478 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:13,479 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{}], channel=org.springframework.integration.amqp.StubRabbitConnectionFactory$StubChannel@42c80fee, acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:13,620 INFO [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Created new connection: SimpleConnection@6c800b8c [delegate=amqp://guest@127.0.0.1:5672/]> 2015-11-16 08:24:13,621 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,1) retrieved from cache> 2015-11-16 08:24:13,621 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,1) is already closed> 2015-11-16 08:24:13,627 DEBUG [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Creating cached Rabbit Channel from AMQChannel(amqp://guest@127.0.0.1:5672/,1)> 2015-11-16 08:24:13,628 DEBUG [org.springframework.amqp.rabbit.core.RabbitTemplate] - <Executing callback on RabbitMQ Channel: Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,1)> 2015-11-16 08:24:13,628 DEBUG [org.springframework.amqp.rabbit.core.RabbitAdmin] - <declaring Queue '3aa6d6dc-c988-41b3-bb9e-99ec7e159e74'> 2015-11-16 08:24:13,631 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Returning cached Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,1)> 2015-11-16 08:24:13,631 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,1) retrieved from cache> 2015-11-16 08:24:13,631 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Found cached Rabbit Channel: Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,1)> 2015-11-16 08:24:13,631 DEBUG [org.springframework.amqp.rabbit.core.RabbitTemplate] - <Executing callback on RabbitMQ Channel: Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,1)> 2015-11-16 08:24:13,631 DEBUG [org.springframework.amqp.rabbit.core.RabbitAdmin] - <Binding destination [3aa6d6dc-c988-41b3-bb9e-99ec7e159e74 (QUEUE)] to exchange [si.fanout.foo] with routing key []> 2015-11-16 08:24:13,633 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Returning cached Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,1)> 2015-11-16 08:24:13,635 DEBUG [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Creating cached Rabbit Channel from AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:13,637 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Started on queue '3aa6d6dc-c988-41b3-bb9e-99ec7e159e74' with tag amq.ctag-0MV-aPvceyTeBSFyc-h1Bg: Consumer: tags=[{amq.ctag-0MV-aPvceyTeBSFyc-h1Bg=3aa6d6dc-c988-41b3-bb9e-99ec7e159e74}], channel=Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2), acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:13,637 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:13,637 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{amq.ctag-0MV-aPvceyTeBSFyc-h1Bg=3aa6d6dc-c988-41b3-bb9e-99ec7e159e74}], channel=Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2), acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:13,638 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <ConsumeOK : Consumer: tags=[{amq.ctag-0MV-aPvceyTeBSFyc-h1Bg=3aa6d6dc-c988-41b3-bb9e-99ec7e159e74}], channel=Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2), acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:14,075 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:14,075 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{amq.ctag-1QiJjvBUKDAcgRoOY973OQ=si.test.queue}], channel=Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,1), acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:14,270 WARN [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Consumer raised exception, processing can restart if the connection factory supports it> java.lang.IllegalArgumentException: Connection must not be null at org.springframework.util.Assert.notNull(Assert.java:115) at org.springframework.amqp.rabbit.connection.RabbitResourceHolder.addConnection(RabbitResourceHolder.java:101) at org.springframework.amqp.rabbit.connection.ConnectionFactoryUtils.doGetTransactionalResourceHolder(ConnectionFactoryUtils.java:136) at org.springframework.amqp.rabbit.connection.ConnectionFactoryUtils.getTransactionalResourceHolder(ConnectionFactoryUtils.java:71) at org.springframework.amqp.rabbit.listener.BlockingQueueConsumer.start(BlockingQueueConsumer.java:456) at org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer$AsyncMessageProcessingConsumer.run(SimpleMessageListenerContainer.java:1165) at java.lang.Thread.run(Thread.java:745) 2015-11-16 08:24:14,271 INFO [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Restarting Consumer: tags=[{}], channel=null, acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:14,271 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Closing Rabbit Channel: null> 2015-11-16 08:24:14,288 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Starting consumer Consumer: tags=[{}], channel=null, acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:14,290 DEBUG [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Recovering consumer in 5000 ms.> 2015-11-16 08:24:14,478 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:14,479 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{}], channel=org.springframework.integration.amqp.StubRabbitConnectionFactory$StubChannel@458912c5, acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:14,479 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:14,479 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{}], channel=org.springframework.integration.amqp.StubRabbitConnectionFactory$StubChannel@6809a22, acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:14,481 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:14,481 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{}], channel=org.springframework.integration.amqp.StubRabbitConnectionFactory$StubChannel@42c80fee, acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:14,640 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:14,640 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{amq.ctag-0MV-aPvceyTeBSFyc-h1Bg=3aa6d6dc-c988-41b3-bb9e-99ec7e159e74}], channel=Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2), acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:14,876 WARN [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Consumer raised exception, processing can restart if the connection factory supports it> java.lang.IllegalArgumentException: Connection must not be null at org.springframework.util.Assert.notNull(Assert.java:115) at org.springframework.amqp.rabbit.connection.RabbitResourceHolder.addConnection(RabbitResourceHolder.java:101) at org.springframework.amqp.rabbit.connection.ConnectionFactoryUtils.doGetTransactionalResourceHolder(ConnectionFactoryUtils.java:136) at org.springframework.amqp.rabbit.connection.ConnectionFactoryUtils.getTransactionalResourceHolder(ConnectionFactoryUtils.java:71) at org.springframework.amqp.rabbit.listener.BlockingQueueConsumer.start(BlockingQueueConsumer.java:456) at org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer$AsyncMessageProcessingConsumer.run(SimpleMessageListenerContainer.java:1165) at java.lang.Thread.run(Thread.java:745) 2015-11-16 08:24:14,876 INFO [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Restarting Consumer: tags=[{}], channel=null, acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:14,876 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Closing Rabbit Channel: null> 2015-11-16 08:24:14,883 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Starting consumer Consumer: tags=[{}], channel=null, acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:14,886 DEBUG [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Recovering consumer in 5000 ms.> 2015-11-16 08:24:15,089 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:15,090 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{amq.ctag-1QiJjvBUKDAcgRoOY973OQ=si.test.queue}], channel=Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,1), acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:15,480 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:15,480 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{}], channel=org.springframework.integration.amqp.StubRabbitConnectionFactory$StubChannel@458912c5, acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:15,481 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:15,481 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{}], channel=org.springframework.integration.amqp.StubRabbitConnectionFactory$StubChannel@6809a22, acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:15,483 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:15,483 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{}], channel=org.springframework.integration.amqp.StubRabbitConnectionFactory$StubChannel@42c80fee, acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:15,641 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:15,642 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{amq.ctag-0MV-aPvceyTeBSFyc-h1Bg=3aa6d6dc-c988-41b3-bb9e-99ec7e159e74}], channel=Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2), acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:16,091 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:16,091 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{amq.ctag-1QiJjvBUKDAcgRoOY973OQ=si.test.queue}], channel=Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,1), acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:16,485 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:16,486 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{}], channel=org.springframework.integration.amqp.StubRabbitConnectionFactory$StubChannel@42c80fee, acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:16,492 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:16,492 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{}], channel=org.springframework.integration.amqp.StubRabbitConnectionFactory$StubChannel@458912c5, acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:16,493 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:16,493 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{}], channel=org.springframework.integration.amqp.StubRabbitConnectionFactory$StubChannel@6809a22, acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:16,644 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:16,644 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{amq.ctag-0MV-aPvceyTeBSFyc-h1Bg=3aa6d6dc-c988-41b3-bb9e-99ec7e159e74}], channel=Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2), acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:17,093 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:17,093 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{amq.ctag-1QiJjvBUKDAcgRoOY973OQ=si.test.queue}], channel=Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,1), acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:17,487 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:17,487 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{}], channel=org.springframework.integration.amqp.StubRabbitConnectionFactory$StubChannel@42c80fee, acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:17,493 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:17,493 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{}], channel=org.springframework.integration.amqp.StubRabbitConnectionFactory$StubChannel@458912c5, acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:17,493 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:17,494 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{}], channel=org.springframework.integration.amqp.StubRabbitConnectionFactory$StubChannel@6809a22, acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:17,647 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:17,647 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{amq.ctag-0MV-aPvceyTeBSFyc-h1Bg=3aa6d6dc-c988-41b3-bb9e-99ec7e159e74}], channel=Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2), acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:18,095 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:18,096 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{amq.ctag-1QiJjvBUKDAcgRoOY973OQ=si.test.queue}], channel=Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,1), acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:18,490 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:18,490 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{}], channel=org.springframework.integration.amqp.StubRabbitConnectionFactory$StubChannel@42c80fee, acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:18,496 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:18,496 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{}], channel=org.springframework.integration.amqp.StubRabbitConnectionFactory$StubChannel@458912c5, acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:18,496 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:18,496 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{}], channel=org.springframework.integration.amqp.StubRabbitConnectionFactory$StubChannel@6809a22, acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:18,648 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:18,648 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{amq.ctag-0MV-aPvceyTeBSFyc-h1Bg=3aa6d6dc-c988-41b3-bb9e-99ec7e159e74}], channel=Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2), acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:19,097 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:19,097 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{amq.ctag-1QiJjvBUKDAcgRoOY973OQ=si.test.queue}], channel=Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,1), acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:19,435 WARN [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Consumer raised exception, processing can restart if the connection factory supports it> java.lang.IllegalArgumentException: Connection must not be null at org.springframework.util.Assert.notNull(Assert.java:115) at org.springframework.amqp.rabbit.connection.RabbitResourceHolder.addConnection(RabbitResourceHolder.java:101) at org.springframework.amqp.rabbit.connection.ConnectionFactoryUtils.doGetTransactionalResourceHolder(ConnectionFactoryUtils.java:136) at org.springframework.amqp.rabbit.connection.ConnectionFactoryUtils.getTransactionalResourceHolder(ConnectionFactoryUtils.java:71) at org.springframework.amqp.rabbit.listener.BlockingQueueConsumer.start(BlockingQueueConsumer.java:456) at org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer$AsyncMessageProcessingConsumer.run(SimpleMessageListenerContainer.java:1165) at java.lang.Thread.run(Thread.java:745) 2015-11-16 08:24:19,435 INFO [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Restarting Consumer: tags=[{}], channel=null, acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:19,435 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Closing Rabbit Channel: null> 2015-11-16 08:24:19,466 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Starting consumer Consumer: tags=[{}], channel=null, acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:19,468 DEBUG [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Recovering consumer in 5000 ms.> 2015-11-16 08:24:19,492 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:19,492 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{}], channel=org.springframework.integration.amqp.StubRabbitConnectionFactory$StubChannel@42c80fee, acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:19,499 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:19,500 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{}], channel=org.springframework.integration.amqp.StubRabbitConnectionFactory$StubChannel@458912c5, acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:19,500 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:19,500 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{}], channel=org.springframework.integration.amqp.StubRabbitConnectionFactory$StubChannel@6809a22, acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:19,651 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:19,651 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{amq.ctag-0MV-aPvceyTeBSFyc-h1Bg=3aa6d6dc-c988-41b3-bb9e-99ec7e159e74}], channel=Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2), acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:20,042 WARN [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Consumer raised exception, processing can restart if the connection factory supports it> java.lang.IllegalArgumentException: Connection must not be null at org.springframework.util.Assert.notNull(Assert.java:115) at org.springframework.amqp.rabbit.connection.RabbitResourceHolder.addConnection(RabbitResourceHolder.java:101) at org.springframework.amqp.rabbit.connection.ConnectionFactoryUtils.doGetTransactionalResourceHolder(ConnectionFactoryUtils.java:136) at org.springframework.amqp.rabbit.connection.ConnectionFactoryUtils.getTransactionalResourceHolder(ConnectionFactoryUtils.java:71) at org.springframework.amqp.rabbit.listener.BlockingQueueConsumer.start(BlockingQueueConsumer.java:456) at org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer$AsyncMessageProcessingConsumer.run(SimpleMessageListenerContainer.java:1165) at java.lang.Thread.run(Thread.java:745) 2015-11-16 08:24:20,042 INFO [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Restarting Consumer: tags=[{}], channel=null, acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:20,042 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Closing Rabbit Channel: null> 2015-11-16 08:24:20,045 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Starting consumer Consumer: tags=[{}], channel=null, acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:20,046 DEBUG [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Recovering consumer in 5000 ms.> 2015-11-16 08:24:20,102 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:20,103 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{amq.ctag-1QiJjvBUKDAcgRoOY973OQ=si.test.queue}], channel=Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,1), acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:20,495 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:20,495 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{}], channel=org.springframework.integration.amqp.StubRabbitConnectionFactory$StubChannel@42c80fee, acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:20,502 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:20,502 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{}], channel=org.springframework.integration.amqp.StubRabbitConnectionFactory$StubChannel@458912c5, acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:20,502 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:20,502 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{}], channel=org.springframework.integration.amqp.StubRabbitConnectionFactory$StubChannel@6809a22, acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:20,671 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:20,671 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{amq.ctag-0MV-aPvceyTeBSFyc-h1Bg=3aa6d6dc-c988-41b3-bb9e-99ec7e159e74}], channel=Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2), acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:21,104 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:21,104 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{amq.ctag-1QiJjvBUKDAcgRoOY973OQ=si.test.queue}], channel=Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,1), acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:21,496 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:21,496 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{}], channel=org.springframework.integration.amqp.StubRabbitConnectionFactory$StubChannel@42c80fee, acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:21,525 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:21,525 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{}], channel=org.springframework.integration.amqp.StubRabbitConnectionFactory$StubChannel@458912c5, acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:21,525 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:21,526 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{}], channel=org.springframework.integration.amqp.StubRabbitConnectionFactory$StubChannel@6809a22, acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:21,673 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:21,673 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{amq.ctag-0MV-aPvceyTeBSFyc-h1Bg=3aa6d6dc-c988-41b3-bb9e-99ec7e159e74}], channel=Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2), acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:22,106 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:22,106 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{amq.ctag-1QiJjvBUKDAcgRoOY973OQ=si.test.queue}], channel=Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,1), acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:22,498 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:22,498 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{}], channel=org.springframework.integration.amqp.StubRabbitConnectionFactory$StubChannel@42c80fee, acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:22,527 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:22,527 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{}], channel=org.springframework.integration.amqp.StubRabbitConnectionFactory$StubChannel@458912c5, acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:22,527 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:22,527 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{}], channel=org.springframework.integration.amqp.StubRabbitConnectionFactory$StubChannel@6809a22, acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:22,676 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:22,676 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{amq.ctag-0MV-aPvceyTeBSFyc-h1Bg=3aa6d6dc-c988-41b3-bb9e-99ec7e159e74}], channel=Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2), acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:23,107 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:23,108 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{amq.ctag-1QiJjvBUKDAcgRoOY973OQ=si.test.queue}], channel=Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,1), acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:23,132 DEBUG [org.springframework.integration.amqp.channel.ChannelTests] - <!!!! Finished test: pubSubLostConnectionTest !!!!> 2015-11-16 08:24:24,567 WARN [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Consumer raised exception, processing can restart if the connection factory supports it> java.lang.IllegalArgumentException: Connection must not be null at org.springframework.util.Assert.notNull(Assert.java:115) at org.springframework.amqp.rabbit.connection.RabbitResourceHolder.addConnection(RabbitResourceHolder.java:101) at org.springframework.amqp.rabbit.connection.ConnectionFactoryUtils.doGetTransactionalResourceHolder(ConnectionFactoryUtils.java:136) at org.springframework.amqp.rabbit.connection.ConnectionFactoryUtils.getTransactionalResourceHolder(ConnectionFactoryUtils.java:71) at org.springframework.amqp.rabbit.listener.BlockingQueueConsumer.start(BlockingQueueConsumer.java:456) at org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer$AsyncMessageProcessingConsumer.run(SimpleMessageListenerContainer.java:1165) at java.lang.Thread.run(Thread.java:745) 2015-11-16 08:24:24,679 DEBUG [org.springframework.integration.amqp.channel.ChannelTests] - <!!!! Starting test: channelDeclarationTests !!!!> 2015-11-16 08:24:24,680 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:24,680 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{amq.ctag-WiUzQGIVjjQPzsjvtNwkmQ=a92d4b20-b227-4aea-8801-67ba92dabdc5}], channel=Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,1), acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:24,682 DEBUG [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Creating cached Rabbit Channel from AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:24,683 DEBUG [org.springframework.amqp.rabbit.core.RabbitTemplate] - <Executing callback on RabbitMQ Channel: Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:24,686 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Returning cached Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:24,687 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2) retrieved from cache> 2015-11-16 08:24:24,687 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Found cached Rabbit Channel: Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:24,687 DEBUG [org.springframework.amqp.rabbit.core.RabbitTemplate] - <Executing callback on RabbitMQ Channel: Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:24,688 DEBUG [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Channel shutdown: channel error; protocol method: #method<channel.close>(reply-code=404, reply-text=NOT_FOUND - no queue 'implicit' in vhost '/', class-id=50, method-id=10)> 2015-11-16 08:24:24,690 DEBUG [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Detected closed channel on exception. Re-initializing: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:24,718 DEBUG [org.springframework.amqp.rabbit.core.RabbitAdmin] - <Queue 'implicit' does not exist> 2015-11-16 08:24:24,718 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Returning cached Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:24,718 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2) retrieved from cache> 2015-11-16 08:24:24,718 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Found cached Rabbit Channel: Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:24,718 DEBUG [org.springframework.amqp.rabbit.core.RabbitTemplate] - <Executing callback on RabbitMQ Channel: Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:24,719 DEBUG [org.springframework.amqp.rabbit.core.RabbitAdmin] - <declaring Queue 'implicit'> 2015-11-16 08:24:24,925 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Returning cached Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:24,926 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2) retrieved from cache> 2015-11-16 08:24:24,926 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Found cached Rabbit Channel: Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:24,926 DEBUG [org.springframework.amqp.rabbit.core.RabbitTemplate] - <Executing callback on RabbitMQ Channel: Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:24,926 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Returning cached Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:24,926 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2) retrieved from cache> 2015-11-16 08:24:24,926 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Found cached Rabbit Channel: Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:24,926 DEBUG [org.springframework.amqp.rabbit.core.RabbitTemplate] - <Executing callback on RabbitMQ Channel: Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:25,107 WARN [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Consumer raised exception, processing can restart if the connection factory supports it> java.lang.IllegalArgumentException: Connection must not be null at org.springframework.util.Assert.notNull(Assert.java:115) at org.springframework.amqp.rabbit.connection.RabbitResourceHolder.addConnection(RabbitResourceHolder.java:101) at org.springframework.amqp.rabbit.connection.ConnectionFactoryUtils.doGetTransactionalResourceHolder(ConnectionFactoryUtils.java:136) at org.springframework.amqp.rabbit.connection.ConnectionFactoryUtils.getTransactionalResourceHolder(ConnectionFactoryUtils.java:71) at org.springframework.amqp.rabbit.listener.BlockingQueueConsumer.start(BlockingQueueConsumer.java:456) at org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer$AsyncMessageProcessingConsumer.run(SimpleMessageListenerContainer.java:1165) at java.lang.Thread.run(Thread.java:745) 2015-11-16 08:24:25,107 INFO [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Restarting Consumer: tags=[{}], channel=null, acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:25,107 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Closing Rabbit Channel: null> 2015-11-16 08:24:25,193 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:25,193 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{amq.ctag-1QiJjvBUKDAcgRoOY973OQ=si.test.queue}], channel=Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,1), acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:25,193 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Starting consumer Consumer: tags=[{}], channel=null, acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:25,199 DEBUG [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Recovering consumer in 5000 ms.> 2015-11-16 08:24:25,318 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Returning cached Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:25,318 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2) retrieved from cache> 2015-11-16 08:24:25,318 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Found cached Rabbit Channel: Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:25,318 DEBUG [org.springframework.amqp.rabbit.core.RabbitTemplate] - <Executing callback on RabbitMQ Channel: Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:25,326 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Returning cached Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:25,326 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2) retrieved from cache> 2015-11-16 08:24:25,326 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Found cached Rabbit Channel: Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:25,326 DEBUG [org.springframework.amqp.rabbit.core.RabbitTemplate] - <Executing callback on RabbitMQ Channel: Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:25,349 DEBUG [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Channel shutdown: channel error; protocol method: #method<channel.close>(reply-code=404, reply-text=NOT_FOUND - no queue 'explicit' in vhost '/', class-id=50, method-id=10)> 2015-11-16 08:24:25,349 DEBUG [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Detected closed channel on exception. Re-initializing: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:25,360 DEBUG [org.springframework.amqp.rabbit.core.RabbitAdmin] - <Queue 'explicit' does not exist> 2015-11-16 08:24:25,361 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Returning cached Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:25,361 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2) retrieved from cache> 2015-11-16 08:24:25,361 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Found cached Rabbit Channel: Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:25,361 DEBUG [org.springframework.amqp.rabbit.core.RabbitTemplate] - <Executing callback on RabbitMQ Channel: Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:25,361 DEBUG [org.springframework.amqp.rabbit.core.RabbitAdmin] - <declaring Queue 'explicit'> 2015-11-16 08:24:25,381 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Returning cached Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:25,382 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2) retrieved from cache> 2015-11-16 08:24:25,382 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Found cached Rabbit Channel: Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:25,382 DEBUG [org.springframework.amqp.rabbit.core.RabbitTemplate] - <Executing callback on RabbitMQ Channel: Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:25,384 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Returning cached Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:25,384 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2) retrieved from cache> 2015-11-16 08:24:25,384 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Found cached Rabbit Channel: Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:25,384 DEBUG [org.springframework.amqp.rabbit.core.RabbitTemplate] - <Executing callback on RabbitMQ Channel: Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:25,505 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:25,505 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{}], channel=org.springframework.integration.amqp.StubRabbitConnectionFactory$StubChannel@42c80fee, acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:25,532 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:25,532 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{}], channel=org.springframework.integration.amqp.StubRabbitConnectionFactory$StubChannel@458912c5, acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:25,559 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:25,559 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{}], channel=org.springframework.integration.amqp.StubRabbitConnectionFactory$StubChannel@6809a22, acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:25,682 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:25,682 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{amq.ctag-WiUzQGIVjjQPzsjvtNwkmQ=a92d4b20-b227-4aea-8801-67ba92dabdc5}], channel=Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,1), acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:26,196 TRACE [org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer] - <Waiting for message from consumer.> 2015-11-16 08:24:26,196 DEBUG [org.springframework.amqp.rabbit.listener.BlockingQueueConsumer] - <Retrieving delivery for Consumer: tags=[{amq.ctag-1QiJjvBUKDAcgRoOY973OQ=si.test.queue}], channel=Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,1), acknowledgeMode=AUTO local queue size=0> 2015-11-16 08:24:26,243 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Returning cached Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:26,243 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2) retrieved from cache> 2015-11-16 08:24:26,243 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Found cached Rabbit Channel: Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:26,244 DEBUG [org.springframework.amqp.rabbit.core.RabbitTemplate] - <Executing callback on RabbitMQ Channel: Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:26,244 DEBUG [org.springframework.amqp.rabbit.core.RabbitAdmin] - <declaring Queue 'explicit'> 2015-11-16 08:24:26,247 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Returning cached Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:26,247 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2) retrieved from cache> 2015-11-16 08:24:26,247 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Found cached Rabbit Channel: Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:26,247 DEBUG [org.springframework.amqp.rabbit.core.RabbitTemplate] - <Executing callback on RabbitMQ Channel: Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:26,249 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Returning cached Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:26,249 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2) retrieved from cache> 2015-11-16 08:24:26,249 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Found cached Rabbit Channel: Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:26,249 DEBUG [org.springframework.amqp.rabbit.core.RabbitTemplate] - <Executing callback on RabbitMQ Channel: Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:26,279 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Returning cached Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:26,279 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2) retrieved from cache> 2015-11-16 08:24:26,279 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Found cached Rabbit Channel: Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:26,280 DEBUG [org.springframework.amqp.rabbit.core.RabbitTemplate] - <Executing callback on RabbitMQ Channel: Cached Rabbit Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:26,429 TRACE [org.springframework.amqp.rabbit.connection.CachingConnectionFactory] - <Returning cached Channel: AMQChannel(amqp://guest@127.0.0.1:5672/,2)> 2015-11-16 08:24:26,430 DEBUG [org.springframework.integration.amqp.channel.ChannelTests] - <!!!! Finished test: channelDeclarationTests !!!!> {code}

    Spring JIRA | 1 year ago | Gary Russell
    com.rabbitmq.client.ShutdownSignalException: channel error; protocol method: #method<channel.close>(reply-code=406, reply-text=PRECONDITION_FAILED - unknown delivery tag 1, class-id=60, method-id=80)
  3. Speed up your debug routine!

    Automated exception search integrated into your IDE

  4. 0

    GitHub comment 24#165218955

    GitHub | 12 months ago | jgawli
    org.springframework.amqp.rabbit.listener.BlockingQueueConsumer$DeclarationException: Failed to declare queue(s):[efm-queue]
  5. 0

    Rabbitmq connection close abruptly on localhost

    Stack Overflow | 11 months ago | user3739116
    org.springframework.amqp.rabbit.listener.BlockingQueueConsumer$DeclarationException: Failed to declare queue(s):[MY_TEST_QU]

  1. poroszd 1 times, last 1 year ago
12 unregistered visitors
Not finding the right solution?
Take a tour to get the most out of Samebug.

Tired of useless tips?

Automated exception search integrated into your IDE

Root Cause Analysis

  1. com.rabbitmq.client.ShutdownSignalException

    channel error; protocol method: #method<channel.close>(reply-code=406, reply-text=PRECONDITION_FAILED - unknown delivery tag 1, class-id=60, method-id=80)

    at com.rabbitmq.client.impl.ChannelN.asyncShutdown()
  2. RabbitMQ Java Client
    AMQConnection$MainLoop.run
    1. com.rabbitmq.client.impl.ChannelN.asyncShutdown(ChannelN.java:484)
    2. com.rabbitmq.client.impl.ChannelN.processAsync(ChannelN.java:321)
    3. com.rabbitmq.client.impl.AMQChannel.handleCompleteInboundCommand(AMQChannel.java:144)
    4. com.rabbitmq.client.impl.AMQChannel.handleFrame(AMQChannel.java:91)
    5. com.rabbitmq.client.impl.AMQConnection$MainLoop.run(AMQConnection.java:554)
    5 frames
  3. Java RT
    Thread.run
    1. java.lang.Thread.run(Thread.java:745)
    1 frame