Split, aggregate, then wait for completionTimeout before continuing

2016-11-03 Thread Craig Washington
Hello, I have a simple use case where I'd like to do the following: * split a message and process each part * aggregate parts into groups of size N for group-processing (w/timeout to ensure no parts are lost) * continue route ONLY after all aggregated parts have completed The simplified route and

Re: Split, aggregate, then wait for completionTimeout before continuing

2016-11-04 Thread Craig Washington
stated the timing doesn’t work after the split/end. On 11/4/16, 2:37 AM, "Claus Ibsen" wrote: See the composed message processor EIP with the splitter only http://camel.apache.org/composed-message-processor.html On Thu, Nov 3, 2016 at 11:32 PM, Craig Washington

Re: CamelTestSupport best way to unit test the OUT or result of the route

2016-11-04 Thread Craig Washington
There are many ways to test your production camel routes – you’ve included a few with Mock and AdviceWith. With this approach you shouldn’t need to include any mock endpoints in your prod route. Instead, in your test you instructing camel to advice the prod route with your mock endpoints. Last

Re: Split, aggregate, then wait for completionTimeout before continuing

2016-11-04 Thread Craig Washington
r only > http://camel.apache.org/composed-message-processor.html > > > On Thu, Nov 3, 2016 at 11:32 PM, Craig Washington > wrote: > > Hello, > > I have a simple use case where I'd like to do the following: > > * split a mes

Re: Split, aggregate, then wait for completionTimeout before continuing

2016-11-04 Thread Craig Washington
That’s correct On 11/4/16, 4:13 PM, "Brad Johnson" wrote: It appears that the splitter is exiting while your aggregator is still stuck waiting for the time out if I'm groking the code right. On Nov 4, 2016 3:49 PM, "Craig Washington" wrot