You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@camel.apache.org by "Claus Ibsen (JIRA)" <ji...@apache.org> on 2013/10/01 11:46:24 UTC
[jira] [Assigned] (CAMEL-6767) rabbitmq component sends basic ack
after channel closed when endpoint is set to autoAck
[ https://issues.apache.org/jira/browse/CAMEL-6767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Claus Ibsen reassigned CAMEL-6767:
----------------------------------
Assignee: Claus Ibsen
> 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)