[
https://issues.apache.org/jira/browse/CAMEL-14335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17003689#comment-17003689
]
michael elbaz edited comment on CAMEL-14335 at 12/26/19 4:22 PM:
-----------------------------------------------------------------
Sorry [~davsclaus] but is exactly what i'm doing this is from the documentation
(https://camel.apache.org/manual/latest/dead-letter-channel.html)
{code:java}
public DeadLetterChannelBuilder myErrorHandler() {
DeadLetterChannelBuilder deadLetterChannelBuilder = new
DeadLetterChannelBuilder();
deadLetterChannelBuilder.setDeadLetterUri(XXX);
deadLetterChannelBuilder.setRedeliveryPolicy(new
RedeliveryPolicy().disableRedelivery());
deadLetterChannelBuilder.useOriginalBody();
deadLetterChannelBuilder.onPrepareFailure(exchange -> {
Exception exception = exchange.getProperty(EXCEPTION_CAUGHT,
Exception.class);
exchange.getIn().removeHeaders(REMOVE_HEADERS_PATTERN);
});
return deadLetterChannelBuilder;
}
// and in my route
.errorHandler(myErrorHandler())
{code}
And is working as expected but just not at startup
was (Author: michael992):
Sorry [~davsclaus] but is exactly what i'm doing this is from the documentation
{code:java}
public DeadLetterChannelBuilder myErrorHandler() {
DeadLetterChannelBuilder deadLetterChannelBuilder = new
DeadLetterChannelBuilder();
deadLetterChannelBuilder.setDeadLetterUri(XXX);
deadLetterChannelBuilder.setRedeliveryPolicy(new
RedeliveryPolicy().disableRedelivery());
deadLetterChannelBuilder.useOriginalBody();
deadLetterChannelBuilder.onPrepareFailure(exchange -> {
Exception exception = exchange.getProperty(EXCEPTION_CAUGHT,
Exception.class);
exchange.getIn().removeHeaders(REMOVE_HEADERS_PATTERN);
});
return deadLetterChannelBuilder;
}
// and in my route
.errorHandler(myErrorHandler())
{code}
> Configuring DLQ
> ---------------
>
> Key: CAMEL-14335
> URL: https://issues.apache.org/jira/browse/CAMEL-14335
> Project: Camel
> Issue Type: Bug
> Components: camel-core
> Affects Versions: 3.0.0
> Reporter: michael elbaz
> Priority: Major
>
> I'm getting weird comportement when i try to use the original body
> {code:java}
> DeadLetterChannelBuilder deadLetterChannelBuilder = new
> DeadLetterChannelBuilder();
> deadLetterChannelBuilder.setRedeliveryPolicy(new
> RedeliveryPolicy().disableRedelivery());
> deadLetterChannelBuilder.useOriginalBody();
> {code}
> When i start my module for the first time is consuming some data from
> rabbitmq then i don't get the original body (when error happen) but the
> transformed one later when i push the same 'wrong' message (without
> restarting my module) i will get the originalBody
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
