[
https://issues.apache.org/jira/browse/CAMEL-6767?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13791444#comment-13791444
]
Claus Ibsen commented on CAMEL-6767:
------------------------------------
Yeah it seems to make sense to only ack if auto ack is disabled.
> rabbitmq component sends basic ack after channel closed when endpoint is set
> to autoAck
> ---------------------------------------------------------------------------------------
>
> Key: CAMEL-6767
> URL: https://issues.apache.org/jira/browse/CAMEL-6767
> Project: Camel
> Issue Type: Bug
> Components: camel-rabbitmq
> Affects Versions: 2.12.0
> Environment: Tested on OSX, JDK 1.7
> Reporter: Dan Revel
> Assignee: Claus Ibsen
> Fix For: 2.12.2, 2.13.0
>
> Attachments: autoack.patch
>
>
> Consuming from a rabbitmq endpoint uri that is configured to autoAck
> generates errors and fails.
> Example URI:
> rabbitmq://localhost:5672/test?autoAck=true&queue=test&autoDelete=false&username=guest&password=guest
> Here's the relevant log output:
> 12:19:03.746 - osis-ht TRACE o.a.c.c.rabbitmq.RabbitMQConsumer -
> Acknowleding receipt [delivery_tag=10]
> 12:19:03.747 - osis-ht WARN o.a.c.c.rabbitmq.RabbitMQConsumer - Error
> processing exchange. Exchange[Message: WTF-9-1379531943713]. Caused by:
> [com.rabbitmq.client.AlreadyClosedException - clean connection shutdown;
> reason: Attempt to use closed channel]
> com.rabbitmq.client.AlreadyClosedException: clean connection shutdown;
> reason: Attempt to use closed channel
> at
> com.rabbitmq.client.impl.AMQChannel.ensureIsOpen(AMQChannel.java:190)
> ~[amqp-client-3.1.3.jar:na]
> at com.rabbitmq.client.impl.AMQChannel.transmit(AMQChannel.java:291)
> ~[amqp-client-3.1.3.jar:na]
> at com.rabbitmq.client.impl.AMQChannel.transmit(AMQChannel.java:285)
> ~[amqp-client-3.1.3.jar:na]
> at com.rabbitmq.client.impl.ChannelN.basicAck(ChannelN.java:907)
> ~[amqp-client-3.1.3.jar:na]
> at
> org.apache.camel.component.rabbitmq.RabbitMQConsumer$RabbitConsumer.handleDelivery(RabbitMQConsumer.java:126)
> ~[camel-rabbitmq-2.12.0.jar:2.12.0]
> at
> com.rabbitmq.client.impl.ConsumerDispatcher$4.run(ConsumerDispatcher.java:121)
> [amqp-client-3.1.3.jar:na]
> at
> com.rabbitmq.client.impl.ConsumerWorkService$WorkPoolRunnable.run(ConsumerWorkService.java:76)
> [amqp-client-3.1.3.jar:na]
> at
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
> [na:1.7.0_21]
> at
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
> [na:1.7.0_21]
> at java.lang.Thread.run(Thread.java:722) [na:1.7.0_21]
--
This message was sent by Atlassian JIRA
(v6.1#6144)
