[
https://issues.apache.org/jira/browse/CAMEL-13267?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16780703#comment-16780703
]
Zoran Regvart commented on CAMEL-13267:
---------------------------------------
[~pbillen] I guess we should set the {{automaticRecoveryEnabled}} to true by
default, we're explicitly setting it from {{null}} to {{false}} (I think
because of a change made in CAMEL-12111). Pull request for that would be very
welcome.
I don't have the answers to your other questions, and I don't think Apache
Camel community is not the place to ask those, perhaps reach out to RabbitMQ
community as Camel is simply utilizing the AMQP client from RabbitMQ.
> Camel stops consuming queue after restart of RabbitMQ broker
> ------------------------------------------------------------
>
> Key: CAMEL-13267
> URL: https://issues.apache.org/jira/browse/CAMEL-13267
> Project: Camel
> Issue Type: Bug
> Components: camel-rabbitmq
> Affects Versions: 2.23.0
> Reporter: Peter Billen
> Priority: Minor
>
> I am consuming a RabbitMQ queue as following:
>
> {code:java}
> from("rabbitmq://localhost:5672?username=test&password=test&declare=false&queue=q&autoAck=false&threadPoolSize=1&exclusiveConsumer=true")
> .to("log:receive");{code}
>
> When I restart the RabbitMQ broker, no messages are longer received in the
> log handler.
>
> According the management interface, all pending messages are in UNACKED
> state. This means that they are transmitted to the consumer, but not
> acknowledged. In other words, Camel was able to restore the connection after
> the restart, but fails to deliver to the log handler and acknowledge them
> afterwards.
>
> I did not test this, but I believe the consumer will eventually crash due to
> OOM.
>
> +*example*+
>
> Please find a self-contained example on
> [https://github.com/pbillen/playground-camel-13267|https://github.com/pbillen/playground-camel-13267].You
> need a (local) Docker daemon to run this. Use it as following:
>
> # Start with `mvn clean install -U`.
> # You notice in the logging that every 500ms, a message is sent and
> received. You can also log into the administrator interface on
> [http://localhost:15672|http://localhost:15672/] with login/password `test`.
> You will see the message pass through every 500ms. Great!
> # Now restart the RabbitMQ broker. Typically, find the container identifier
> with `docker ps` and then execute `docker restart <identifier>`.
> # After restart, you notice that every 500ms a message is sent, but not
> received. You can also log into the administrator interface and see that all
> messages are into the UNACKED state.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
