org.springframework.amqp.AmqpIOException: java.io.IOException: Unknown consumerTag

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
    org.springframework.amqp.AmqpIOException: java.io.IOException: Unknown consumerTag
  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
    org.springframework.amqp.AmqpIOException: java.io.IOException: Unknown consumerTag
  3. 0

    Exception when quitting using rabbitmq/amqp inputs

    Google Groups | 3 years ago | nitin
    java.io.IOException: Unknown consumerTag
  4. Speed up your debug routine!

    Automated exception search integrated into your IDE

    1 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. java.io.IOException

      Unknown consumerTag

      at com.rabbitmq.client.impl.ChannelN.basicCancel()
    2. RabbitMQ Java Client
      ChannelN.basicCancel
      1. com.rabbitmq.client.impl.ChannelN.basicCancel(ChannelN.java:1117)
      1 frame
    3. Java RT
      Method.invoke
      1. sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
      2. sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
      3. sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
      4. java.lang.reflect.Method.invoke(Method.java:497)
      4 frames
    4. Spring RabbitMQ Support
      CachingConnectionFactory$CachedChannelInvocationHandler.invoke
      1. org.springframework.amqp.rabbit.connection.CachingConnectionFactory$CachedChannelInvocationHandler.invoke(CachingConnectionFactory.java:704)
      1 frame
    5. com.sun.proxy
      $Proxy28.basicCancel
      1. com.sun.proxy.$Proxy28.basicCancel(Unknown Source)
      1 frame
    6. Spring RabbitMQ Support
      SimpleMessageListenerContainer$AsyncMessageProcessingConsumer.run
      1. org.springframework.amqp.rabbit.connection.RabbitUtils.closeMessageConsumer(RabbitUtils.java:124)
      2. org.springframework.amqp.rabbit.listener.BlockingQueueConsumer.stop(BlockingQueueConsumer.java:586)
      3. org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer.restart(SimpleMessageListenerContainer.java:994)
      4. org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer.access$3000(SimpleMessageListenerContainer.java:93)
      5. org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer$AsyncMessageProcessingConsumer.run(SimpleMessageListenerContainer.java:1322)
      5 frames
    7. Java RT
      Thread.run
      1. java.lang.Thread.run(Thread.java:745)
      1 frame