gistfile1.java

public class CheapeastFlightAggregationStrategy implements AggregationStrategy {

	@Override
	public MuleEvent aggregate(AggregationContext context) throws MuleException {
		MuleEvent result = null;
		long value = Long.MAX_VALUE;
		for (MuleEvent event : context.collectEventsWithoutExceptions()) {
			Flight flight = (Flight) event.getMessage().getPayload(); 
			if (flight.getCost() < value) {
				result = DefaultMuleEvent.copy(event);
				value = flight.getCost();
			}
		}
		
		if (result != null)  {
			return result;
		}
		
		throw new  RuntimeException("no flights obtained");
	}
}