<route id="EbayRoute-Prod1">
<camel:from
uri="wmq-qm1-Prod1-Ebay:queue:{{financial.WMQ.EbaySubQueue}}"></camel:from>
<process ref="setHeaders-Prod1" />
<aggregate strategyRef="myAggregationStrategy-Prod1"
prop:completionInterval="{{financial.Aggregation.EbayCompletionInterval}}">
<correlationExpression>
<constant>true</constant>
</correlationExpression>
<camel:to uri="direct:EbayOutQueue1"></camel:to>
</aggregate>
</route>
<route id="EbayRoute2-Prod1">
<camel:from uri="direct:EbayOutQueue1"></camel:from>
<process ref="createEbayMessage-Prod">
<description>
Original payload message in one queue
like our ORIG
queues
Generate exception message in java code
</description>
</process>
<camel:to
uri="wmq-qm1-Prod1-Ebay:queue:{{financial.WMQ.EbayOutQueue}}"></camel:to>
</route>
Thanks and Regards,
Vanshul Chawla
-----Original Message-----
From: Vanshul.Chawla [mailto:[email protected]]
Sent: Wednesday, July 15, 2015 12:36 PM
To: [email protected]
Subject: Camel aggregation in case of server shutdown
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
