public class ResponseCorrelationAggregator.DefaultEventCorrelatorCallback extends Object implements EventCorrelatorCallback
Constructor and Description |
---|
ResponseCorrelationAggregator.DefaultEventCorrelatorCallback() |
Modifier and Type | Method and Description |
---|---|
MuleMessage |
aggregateEvents(EventGroup events)
This method is invoked if the shouldAggregate method is called and returns
true.
|
EventGroup |
createEventGroup(MuleEvent event,
Object id)
Creates the event group with a specific correlation size based on the Mule
Correlation support
|
boolean |
shouldAggregateEvents(EventGroup events)
Determines if the event group is ready to be aggregated.
|
public ResponseCorrelationAggregator.DefaultEventCorrelatorCallback()
public MuleMessage aggregateEvents(EventGroup events) throws RoutingException
aggregateEvents
in interface EventCorrelatorCallback
events
- the event group for this requestAggregationException
- if the aggregation fails. in this scenario the
whole event group is removed and passed to the exception handler
for this componentRoutingException
public boolean shouldAggregateEvents(EventGroup events)
shouldAggregateEvents
in interface EventCorrelatorCallback
events
- public EventGroup createEventGroup(MuleEvent event, Object id)
EventCorrelatorCallback
createEventGroup
in interface EventCorrelatorCallback
event
- the current eventid
- The group idCopyright © 2003–2013 MuleSource, Inc.. All rights reserved.