Currently I'm working on a few different prototypes for a large project and
Camel is been used in one of these prototypes.
Is there anyway in Camel (1.3.0RC2) to provide you own implementation for a
AggregationCollection? I've created an AggregationStrategy that is backed
by a persisted collection based off the same correlation id used by the
aggregator. I've tested this for fail over and all is working fine except
for when a crash occurs before I receive the last message or after I receive
the first message. When the last message is received after a crash then my
AggregationStrategy is never called because oldExchange is on longer in
memory:-
if (oldExchange != null) {
newExchange = aggregationStrategy.aggregate(oldExchange,
newExchange);
}
Likewise my first message is never persisted because the oldExchange was
never in memory! (Note that i'm not acually persisting the full message
just the parts of the body I need).
In fact you could agure that AggregationCollection is doing to much work in
keeping onto the old message.
--
View this message in context:
http://www.nabble.com/AggregationCollection-implementation-tp15891263s22882p15891263.html
Sent from the Camel - Users mailing list archive at Nabble.com.
