[
https://issues.apache.org/jira/browse/CAMEL-4097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13106580#comment-13106580
]
Ben O'Day commented on CAMEL-4097:
----------------------------------
thanks Claus, I see what you are talking about now...didn't realize that
another thread was being used in onCompletion() to send out the exchanges. It
sounds like something like this should do it, correct?
{code}
if (forceCompletionOnStop) {
forceCompletionOfAllGroups();
while(inProgressCompleteExchanges.size() > 0) {
LOG.debug("waiting for {} in progress exchanges to complete",
inProgressCompleteExchanges.size());
Thread.sleep(100);
}
}
{code}
> Add option on aggregation to flush on shutdown
> ----------------------------------------------
>
> Key: CAMEL-4097
> URL: https://issues.apache.org/jira/browse/CAMEL-4097
> Project: Camel
> Issue Type: New Feature
> Components: camel-core
> Reporter: Claus Ibsen
> Assignee: Ben O'Day
> Priority: Minor
> Fix For: 2.9.0
>
> Attachments: CAMEL-4097.patch
>
>
> We may want to add options to stateful EIPs such as aggregator/resequencer
> that they should flush on shutdown. People who dont use a persistent store
> would loose the in-memory partly aggregated exchanges.
> See nabble
> http://camel.465427.n5.nabble.com/Aggregator-completeOnShutdown-tp4423774p4423774.html
--
This message is automatically generated by JIRA.
For more information on JIRA, see: http://www.atlassian.com/software/jira
