here is the code:
public class AggregationSimple implements AggregationStrategy {
/** Logger de la classe. */
private static final Logger LOGGER =
Logger.getLogger(AggregationSimple.class);
public Exchange aggregate(final Exchange pOldExchange,
final Exchange pNewExchange) {
if (pOldExchange == null) {
if (LOGGER.isDebugEnabled()) {
LOGGER.debug("1er passage " + pNewExchange);
}
final String text = pNewExchange.getIn().getBody(String.class);
pNewExchange.getIn().setBody(text);
} else {
if (LOGGER.isDebugEnabled()) {
LOGGER.debug("Aggregation de : " + pOldExchange + "/" +
pNewExchange);
}
final String text = pOldExchange.getIn().getBody(String.class);
final String text2 = pNewExchange.getIn().getBody(String.class);
pNewExchange.getIn().setBody(text + "/aggregation/" + text2);
}
return pNewExchange;
}
}
--
View this message in context:
http://camel.465427.n5.nabble.com/problem-with-exception-in-the-recipientList-tp5779499p5779511.html
Sent from the Camel - Users mailing list archive at Nabble.com.
