camel-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Willem Jiang (JIRA)" <j...@apache.org>
Subject [jira] [Updated] (CAMEL-7665) RabbitMq don't reject messages when consumer or endpoint fail.
Date Mon, 11 Aug 2014 14:13:12 GMT

     [ https://issues.apache.org/jira/browse/CAMEL-7665?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]

Willem Jiang 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:
{code}
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");
{code}
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://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.


> 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
>             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:
> {code}
> 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");
> {code}
> Using errorHandler(deadLetterChannel("..another queue") the message is Redelivered in
same queue.



--
This message was sent by Atlassian JIRA
(v6.2#6252)

Mime
View raw message