You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@camel.apache.org by "Dan Revel (JIRA)" <ji...@apache.org> on 2013/09/18 21:21:51 UTC

[jira] [Created] (CAMEL-6767) rabbitmq component sends basic ack after channel closed when endpoint is set to autoAck

Dan Revel created CAMEL-6767:
--------------------------------

             Summary: 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
    Affects Versions: 2.12.0
         Environment: Tested on OSX, JDK 1.7
            Reporter: Dan Revel


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 is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators
For more information on JIRA, see: http://www.atlassian.com/software/jira