public class CollectionCorrelatorCallback extends Object implements EventCorrelatorCallback
Modifier and Type | Field and Description |
---|---|
protected org.apache.commons.logging.Log |
logger
logger used by this class
|
Constructor and Description |
---|
CollectionCorrelatorCallback() |
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 groupId)
Creates a new EventGroup that will expect the number of events as returned by
MessageAdapter.getCorrelationGroupSize() . |
boolean |
shouldAggregateEvents(EventGroup events)
Determines if the event group is ready to be aggregated.
|
protected final transient org.apache.commons.logging.Log logger
public MuleMessage aggregateEvents(EventGroup events) throws AggregationException
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 componenetpublic EventGroup createEventGroup(MuleEvent event, Object groupId)
MessageAdapter.getCorrelationGroupSize()
.createEventGroup
in interface EventCorrelatorCallback
event
- the current eventgroupId
- The group idpublic boolean shouldAggregateEvents(EventGroup events)
EventCorrelatorCallback
shouldAggregateEvents
in interface EventCorrelatorCallback
events
- The current event group received by the correlatortrue
if the correlation size is not set or exactly the
expected size of the event group.org.mule.routing.inbound.AbstractEventAggregator#shouldAggregateEvents(EventGroup)
Copyright © 2003–2013 MuleSource, Inc.. All rights reserved.