Hi,
In my aggregationstratgy route, sometimes (1 out of 10000) i get message
body as null in the newExchange.. I have no clue whats wrong.
Thought of trying the retry with default error handler. But Aggregator
doesn't support throwing an exception. Is there any alternative to
aggregator ?
restConfiguration().component("restlet")
.componentProperty("maxQueued", "-1")
.componentProperty("persistingConnections", "true")
.componentProperty("pipeliningConnections", "true")
.host("localhost").port(Constants.ROUTINGPORT).bindingMode(RestBindingMode.off);
rest("api/v1").
post("/collector").
consumes("application/octet-stream").
route().routeId("Collector Inlet").
to("seda:aggregate?waitForTaskToComplete=Never");
from("seda:aggregate").
routeId("Message Aggregation").
setHeader("id", constant("n/a")).
aggregate(header("id"), new MessageAggregation()).
completionSize(Constants.BATCHSIZE).
to("seda:process?waitForTaskToComplete=Never");
--
View this message in context:
http://camel.465427.n5.nabble.com/Redelivery-of-message-in-case-of-exception-inside-aggregator-tp5799551.html
Sent from the Camel - Users mailing list archive at Nabble.com.
