[
https://issues.apache.org/jira/browse/CAMEL-11530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Arnaud CHOTARD updated CAMEL-11530:
-----------------------------------
Attachment: queue.png
channel.png
connections.png
jmx.png
> RabbitMQ component doesn't handle network failure properly when using
> autoAck=false and automaticRecovery=true
> --------------------------------------------------------------------------------------------------------------
>
> Key: CAMEL-11530
> URL: https://issues.apache.org/jira/browse/CAMEL-11530
> Project: Camel
> Issue Type: Bug
> Components: camel-rabbitmq
> Affects Versions: 2.17.6
> Environment: RabbitMQ 3.5.7
> Reporter: Arnaud CHOTARD
> Attachments: channel.png, connections.png, jmx.png, queue.png
>
>
> When using autoAck=false and automaticRecoveryEnabled=true on Camel RabbitMQ
> consumer, we are facing problem during network failure recovery on our
> production environments.
> Before CAMEL-8742, tested with Camel 2.16.2, the automatic recovery is
> managed directly by RabbitMQ native client. When network failure is
> recovering, the old channel is reconnect and messages are proccessed
> correctly.
> After CAMEL-8742, tested with Camel 2.17.6, the Camel RabbitMQ component open
> new channel when network failure is recovering. On the other hand, RabbitMQ
> native client will also reconnect old channels when using
> automaticRecoveryEnabled=true. So two channel are now open. The two recovery
> method make conflict. As consequence, new messages publish in RabbitMQ remain
> unacked and the Camel exchange are not processing on Camel route.
> To recover from this, we should delete, recreate the queue in production
> environment and restart Camel application. So, the unacked messages are being
> lost.
> What do you think of this problem ?
> Thank you
> Camel RabbitMQ Consumer Route :
> {code:java}
> from("rabbitmq:///?" +
> "connectionFactory=#brokerConnectionFactory" +
> "&addresses=" + brokerAdresses +
> "&queue="+ brokerQueue +
> "&declare=false" +
> "&autoDelete=false" +
> "&autoAck=false"
> )
> .bean("<beanName>", "<beanMethod>");
> {code}
> RabbitMQ Connection Factory with automaticRecoveryEnabled=true
> {code}
> <bean id="brokerConnectionFactory"
> class="com.rabbitmq.client.ConnectionFactory">
> <property name="host" value="${broker.hostname}"/>
> <property name="virtualHost" value="${broker.virtualHost:/}"/>
> <property name="port" value="${broker.port:5672}"/>
> <property name="username" value="${broker.username}"/>
> <property name="password" value="${broker.password}"/>
> <property name="automaticRecoveryEnabled" value="true"/>
> </bean>
> {code}
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
