You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@camel.apache.org by "Ramon Rosa da Silva (JIRA)" <ji...@apache.org> on 2014/08/06 20:50:12 UTC
[jira] [Updated] (CAMEL-7665) RabbitMq don't reject messages when
consumer or endpoint fail.
[ https://issues.apache.org/jira/browse/CAMEL-7665?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Ramon Rosa da Silva updated CAMEL-7665:
---------------------------------------
Description:
RabbitMQ does not execute command to reject a message when consumers or end point throws an exception or shutdown is executed by karaf.
We need execute channel.basicReject(deliveryTag, false) to send message to Dead Letter Exchange.
In current implementation the message is always acknowledged.
Scenario:
from("rabbitmq://localhost:5672/myFailTest?"
+"routingKey=myFailTest&queue=myFailTest&exchangeType=direct"
+ "&vhost=test&durable=true&autoDelete=false"
+ "&autoAck=false&username=guest&password=guest")
.to("ftp://localhost/notExists?connectTimeout=100&timeout=100");
Using errorHandler(deadLetterChannel("..another queue") the message is Redelivered in same queue.
was:
RabbitMQ does not execute command to reject a message when consumers or end point throws an exception or shutdown is executed by karaf.
We need execute channel.basicReject(deliveryTag, false) to send message to Dead Letter Exchange.
In current implementation the message is always acknowledged.
Scenario:
from("rabbitmq://rabbit-alpha:5672/myFailTest?"
+"routingKey=myFailTest&queue=myFailTest&exchangeType=direct"
+ "&vhost=ngproxy&durable=true&autoDelete=false"
+ "&autoAck=false&username=guest&password=guest")
.to("ftp://localhost/notExists?connectTimeout=100&timeout=100");
Using errorHandler(deadLetterChannel("..another queue") the message is Redelivered in same queue.
> RabbitMq don't reject messages when consumer or endpoint fail.
> --------------------------------------------------------------
>
> Key: CAMEL-7665
> URL: https://issues.apache.org/jira/browse/CAMEL-7665
> Project: Camel
> Issue Type: Bug
> Components: camel-rabbitmq
> Affects Versions: 2.13.2
> Reporter: Ramon Rosa da Silva
> Priority: Critical
> Fix For: 2.14.0
>
>
> RabbitMQ does not execute command to reject a message when consumers or end point throws an exception or shutdown is executed by karaf.
> We need execute channel.basicReject(deliveryTag, false) to send message to Dead Letter Exchange.
> In current implementation the message is always acknowledged.
> Scenario:
> from("rabbitmq://localhost:5672/myFailTest?"
> +"routingKey=myFailTest&queue=myFailTest&exchangeType=direct"
> + "&vhost=test&durable=true&autoDelete=false"
> + "&autoAck=false&username=guest&password=guest")
> .to("ftp://localhost/notExists?connectTimeout=100&timeout=100");
> Using errorHandler(deadLetterChannel("..another queue") the message is Redelivered in same queue.
--
This message was sent by Atlassian JIRA
(v6.2#6252)