[
https://issues.apache.org/jira/browse/CAMEL-14473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Muhammed Shanid A K updated CAMEL-14473:
----------------------------------------
Description:
- 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 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://[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}
was:
- 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}
> 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 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://[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)
