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

["Muhammed Shanid A K (Jira)" <ji...@apache.org>]

Muhammed Shanid A K created CAMEL-14473:
-------------------------------------------

             Summary: 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


 -  Consumer not receiving the message from one of the queue after the restart of rabbitMQ pods ( Not always , intermittently ) ( Queue is 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 consumer 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)