How do you aggregate them? If you use the Camel aggregator then its by default in-memory only, and you would loose those messages. There is pluggable persistent stores, but they have their own pros/cons.
Its better to stop the consumer that takes in new messages, and wait for the aggregator batch to complete so there is no inflight, and then stop. You can also enable forceCompletionOnStop on the aggregator then it flushes out all in-flight exchanges so you can stop quicker. In fact it may be the option you are looking for. On Wed, Jul 15, 2015 at 9:06 AM, Vanshul.Chawla <[email protected]> wrote: > Hello All, > > We have a scenario wherein we aggregate message coming from a IBM MQ queue > for 15 minutes before spitting a batch out to another MQ. > Suppose we have a server shutdown at 10th minute, what will happen to > inflight messages? Will these be lost? Or will Fuse server restart get these > messages and flush them out to destination. > > Thanks and Regards, > > Vanshul Chawla > -- Claus Ibsen ----------------- http://davsclaus.com @davsclaus Camel in Action 2nd edition: http://www.manning.com/ibsen2
