camel-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Claus Ibsen (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (CAMEL-6767) rabbitmq component sends basic ack after channel closed when endpoint is set to autoAck
Date Thu, 10 Oct 2013 12:39:45 GMT

    [ 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)

Mime
View raw message