|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public interface EventCorrelatorCallback
A callback used to allow pluggable behaviour when correlating events
Method Summary | |
---|---|
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. |
Method Detail |
---|
boolean shouldAggregateEvents(EventGroup events)
events
- The current event group received by the correlator
MuleMessage aggregateEvents(EventGroup events) throws RoutingException
events
- the event group for this request
AggregationException
- if the aggregation fails. in this scenario the
whole event group is removed and passed to the exception handler
for this component
RoutingException
EventGroup createEventGroup(MuleEvent event, Object id)
id
- The group idevent
- the current event
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |