[ https://issues.apache.org/jira/browse/CAMEL-14473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17028733#comment-17028733 ]
Dmitry Volodin commented on CAMEL-14473: ---------------------------------------- [~mohdshani...@gmail.com] it can be related to the CAMEL-13267 issue or any latest fix for 2.24.latest, 2.25.x or 3.x Please try with the latest stable Camel release and return back. > Consumer is not receiving the message from one of the queue after the > RabbitMQ pods is restarted or Node is terminated > ---------------------------------------------------------------------------------------------------------------------- > > Key: CAMEL-14473 > URL: https://issues.apache.org/jira/browse/CAMEL-14473 > Project: Camel > Issue Type: Bug > Components: camel-rabbitmq > Affects Versions: 2.24.0 > Environment: {code:java} > {code} > Reporter: Muhammed Shanid A K > Priority: Major > > - 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 > {code:java} > "?exchangeType=fanout" > + "&durable=false&autoDelete=true&queue=abc-" + > hostOrProcessName{code} > Below error is present in the application log. > {code:java} > "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) > {code} > > > -- This message was sent by Atlassian Jira (v8.3.4#803005)