[CAMEL-14473] Consumer is not receiving the message from one of the queue after the RabbitMQ pods is restarted or Node is terminated

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Duplicate
• Affects Version/s: 2.24.0
• Component/s: camel-rabbitmq

Environment

• Estimated Complexity: Unknown
• Assignee: Unassigned
• Reporter: Muhammed Shanid A K
• Created: 03/Feb/20 05:14
• Updated: 03/Feb/20 07:45
• Resolved: 03/Feb/20 07:45

Description

 -  Consumer not receiving the message from one of the queue after the restart of rabbitMQ pods ( Not always , intermittently ) ( Queue is not present for the consumer when checked via RabbitMQ management console ).

 - Using high Availability rabbit MQ Kubernetes service.

-  connecting to rabbitQueue  as 

"?exchangeType=fanout"
             + "&durable=false&autoDelete=true&queue=abc-" + hostOrProcessName

Below error is present in the application log.

"2020-02-02 01:05:23.767 ERROR --- [abbitMQConsumer] mq.client.impl.ForgivingExceptionHandler                 -  : Consumer org.apache.camel.component.rabbitmq.RabbitConsumer@437dba4d (amq.ctag-N3IUnRHiiOb) method handleCancel for channel AMQChannel(amqp://guest@187.34.72.463:5672/,1) threw an exception for channel AMQChannel(amqp://guest@187.34.72.463:5672/,1)java.io.IOException
\tat com.rabbitmq.client.impl.AMQChannel.wrap(AMQChannel.java:126)
\tat com.rabbitmq.client.impl.AMQChannel.wrap(AMQChannel.java:122)
\tat com.rabbitmq.client.impl.AMQChannel.exnWrappingRpc(AMQChannel.java:144)
\tat com.rabbitmq.client.impl.ChannelN.queueDeclare(ChannelN.java:962)
\tat com.rabbitmq.client.impl.recovery.AutorecoveringChannel.queueDeclare(AutorecoveringChannel.java:333)
\tat org.apache.camel.component.rabbitmq.RabbitMQDeclareSupport.declareAndBindQueue(RabbitMQDeclareSupport.java:141)
\tat org.apache.camel.component.rabbitmq.RabbitMQDeclareSupport.declareAndBindExchangeWithQueue(RabbitMQDeclareSupport.java:55)
\tat org.apache.camel.component.rabbitmq.RabbitMQDeclareSupport.declareAndBindExchangesAndQueuesUsing(RabbitMQDeclareSupport.java:36)
\tat org.apache.camel.component.rabbitmq.RabbitMQEndpoint.declareExchangeAndQueue(RabbitMQEndpoint.java:241)
\tat org.apache.camel.component.rabbitmq.RabbitConsumer.handleCancel(RabbitConsumer.java:247)
\tat com.rabbitmq.client.impl.ConsumerDispatcher$3.run(ConsumerDispatcher.java:115)
\tat com.rabbitmq.client.impl.ConsumerWorkService$WorkPoolRunnable.run(ConsumerWorkService.java:104)
\tat java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
\tat java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
\tat java.lang.Thread.run(Thread.java:748)
Caused by: com.rabbitmq.client.ShutdownSignalException: channel error; protocol method: #method<channel.close>(reply-code=404, reply-text=NOT_FOUND - queue 'abc-myservice-6c4b868767-mtbnx3' in vhost '/' process is stopped by supervisor, class-id=50, method-id=10)