[
https://issues.apache.org/jira/browse/CAMEL-13789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
michael elbaz updated CAMEL-13789:
----------------------------------
Description:
Messages are always ack (consumer) even on exception
https://stackoverflow.com/questions/48941888/rabbitmq-and-camel-2-20-auto-acknowledges-even-when-autoack-false
{code:java}
@Override
public void configure() throws Exception {
from(rabbitMq())
.routeId(ROUTE_ID)
.throwException(new Exception("2222"))
.log("test");
}
private String rabbitMq() {
StringBuilder rabbit = new StringBuilder("rabbitmq:").append("test");
rabbit.append("?queue=");
rabbit.append("test");
rabbit.append("&prefetchEnabled=");
rabbit.append(true);
rabbit.append("&concurrentConsumers=");
rabbit.append(1);
rabbit.append("&threadPoolSize=");
rabbit.append(1);
rabbit.append("&prefetchCount=");
rabbit.append(50);
return rabbit.toString();
}
{code}
was:
Messages are always ack (consumer) even on exception this is not fixed in
2.20.2 Claus
https://stackoverflow.com/questions/48941888/rabbitmq-and-camel-2-20-auto-acknowledges-even-when-autoack-false
{code:java}
@Override
public void configure() throws Exception {
from(rabbitMq())
.routeId(ROUTE_ID)
.throwException(new Exception("2222"))
.log("test");
}
private String rabbitMq() {
StringBuilder rabbit = new StringBuilder("rabbitmq:").append("test");
rabbit.append("?queue=");
rabbit.append("test");
rabbit.append("&prefetchEnabled=");
rabbit.append(true);
rabbit.append("&concurrentConsumers=");
rabbit.append(1);
rabbit.append("&threadPoolSize=");
rabbit.append(1);
rabbit.append("&prefetchCount=");
rabbit.append(50);
return rabbit.toString();
}
{code}
> Always ack even on fails exchange
> ---------------------------------
>
> Key: CAMEL-13789
> URL: https://issues.apache.org/jira/browse/CAMEL-13789
> Project: Camel
> Issue Type: Bug
> Components: camel-rabbitmq
> Affects Versions: 2.24.1, 3.0.0.M4
> Reporter: michael elbaz
> Priority: Major
>
> Messages are always ack (consumer) even on exception
> https://stackoverflow.com/questions/48941888/rabbitmq-and-camel-2-20-auto-acknowledges-even-when-autoack-false
> {code:java}
> @Override
> public void configure() throws Exception {
> from(rabbitMq())
> .routeId(ROUTE_ID)
> .throwException(new Exception("2222"))
> .log("test");
> }
> private String rabbitMq() {
> StringBuilder rabbit = new StringBuilder("rabbitmq:").append("test");
> rabbit.append("?queue=");
> rabbit.append("test");
> rabbit.append("&prefetchEnabled=");
> rabbit.append(true);
> rabbit.append("&concurrentConsumers=");
> rabbit.append(1);
> rabbit.append("&threadPoolSize=");
> rabbit.append(1);
> rabbit.append("&prefetchCount=");
> rabbit.append(50);
> return rabbit.toString();
> }
> {code}
--
This message was sent by Atlassian JIRA
(v7.6.14#76016)
