Multicast Timeout

["bob.rogers@cigna.com" <bo...@cigna.com>]

I am using multicast and have implemented AggregationStrategy java class
which implements the TimeoutAwareAggregationStrategy interface.

In the:

   public Exchange aggregate(Exchange oldExchange, Exchange newExchange)
method I am grabbing the body of the newExchange and adding it to a list.  I
then add a property that references the list.  During the next execution of 
aggregate(Exchange oldExchange, Exchange newExchange) I get the property
(list) from the oldExchange and add the body from the newExchange to the
list.

public Exchange aggregate(Exchange oldExchange, Exchange newExchange) {
		LOGGER.debug("ENTER::::AggregateCpfPrdsImpl>aggregate");
		if (oldExchange == null) {
			List<Document> responses = new ArrayList<Document>();
			Object oBody = newExchange.getIn().getBody(Document.class);
	     	        Document response = (Document) oBody;      	
	     	        response.normalizeDocument(); 
			responses.add(response);
			newExchange.setProperty(RESPONSES, responses);
			LOGGER.info("EXCHANGE-newExchange " + newExchange.toString());
			logResponse("AggregationStrategy first response:  ", response);
		}
		else {

			List<Document> responses = (List<Document>)
oldExchange.getProperty(RESPONSES);
			Object oBody = newExchange.getIn().getBody(Document.class);
	     	        Document response = (Document) oBody;      	
	     	        response.normalizeDocument(); 
			responses.add(response);
			newExchange.setProperty(RESPONSES, responses);
			LOGGER.info("oldExhange " + oldExchange.toString());
			LOGGER.info("newExhange " + newExchange.toString());
			logResponse("AggregationStrategy second response:  ", response);
		}
		return newExchange;

The problem I face is when there is a timeout condition the exchange object
in my camel route after the multicast doesn't have the RESPONSES property
(list).  If I don't face the timeout, then the exchange object has the
RESPONSES property.

Any help would be appreciated.





--
View this message in context: http://camel.465427.n5.nabble.com/Multicast-Timeout-tp5804638.html
Sent from the Camel - Users mailing list archive at Nabble.com.