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://[email protected]:5672/,1) threw an exception for channel
AMQChannel(amqp://[email protected]: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)
