org.mule.routing
Class CollectAllAggregationStrategy

java.lang.Object
  org.mule.routing.CollectAllAggregationStrategy

All Implemented Interfaces:

AggregationStrategy

public class CollectAllAggregationStrategy
extends Object
implements AggregationStrategy

If no routes generated exeption then it returns a new MuleEvent under the rules of DefaultRouterResultsHandler (you can change this behaviour by overriding aggregateWithoutFailedRoutes(AggregationContext). Otherwise, a CompositeRoutingException is thrown (override to customize

Since:

3.5.0

Constructor Summary

CollectAllAggregationStrategy()

Method Summary

MuleEvent	aggregate(AggregationContext context) aggregates the events in the given context into a single one
protected MuleEvent	aggregateWithFailedRoutes(AggregationContext context)
protected MuleEvent	aggregateWithoutFailedRoutes(AggregationContext context)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

CollectAllAggregationStrategy

public CollectAllAggregationStrategy()

Method Detail

aggregate

public MuleEvent aggregate(AggregationContext context)
                    throws MuleException

Description copied from interface: AggregationStrategy

aggregates the events in the given context into a single one

Specified by:

aggregate in interface AggregationStrategy

Parameters:

context - an instance of AggregationContext

Returns:

a resulting MuleEvent. It can be a new event, an enriched version of AggregationContext.getOriginalEvent() or whatever makes sense in your use case. It cannot be null, return VoidMuleEvent instead

Throws:

MuleException - if unexpected exception occurs or business error condition is met

aggregateWithoutFailedRoutes

protected MuleEvent aggregateWithoutFailedRoutes(AggregationContext context)
                                          throws MuleException

Throws:

MuleException

aggregateWithFailedRoutes

protected MuleEvent aggregateWithFailedRoutes(AggregationContext context)
                                       throws MuleException

Throws:

MuleException