Package | Description |
---|---|
org.mule.routing |
Defines the core routing patterns supported by mule.
|
org.mule.routing.correlation |
Modifier and Type | Method and Description |
---|---|
EventGroup |
AggregationException.getEventGroup() |
Modifier and Type | Method and Description |
---|---|
protected abstract MuleEvent |
AbstractCorrelationAggregator.aggregateEvents(EventGroup events) |
int |
EventGroup.compareTo(EventGroup other)
Compare this EventGroup to another one.
|
Constructor and Description |
---|
AggregationException(EventGroup eventGroup,
MessageProcessor endpoint) |
AggregationException(EventGroup eventGroup,
MessageProcessor endpoint,
Throwable cause) |
AggregationException(Message message,
EventGroup eventGroup,
MessageProcessor endpoint) |
AggregationException(Message message,
EventGroup eventGroup,
MessageProcessor endpoint,
Throwable cause) |
Modifier and Type | Field and Description |
---|---|
protected ListableObjectStore<EventGroup> |
EventCorrelator.eventGroups
A map of EventGroup objects.
|
Modifier and Type | Method and Description |
---|---|
protected EventGroup |
EventCorrelator.addEventGroup(EventGroup group) |
EventGroup |
EventCorrelatorCallback.createEventGroup(MuleEvent event,
Object id)
Creates the event group with a specific correlation size based on the Mule
Correlation support
|
EventGroup |
CollectionCorrelatorCallback.createEventGroup(MuleEvent event,
Object groupId)
Creates a new EventGroup that will expect the number of events as returned by
MuleMessage.getCorrelationGroupSize() . |
protected EventGroup |
EventCorrelator.getEventGroup(Serializable groupId) |
Modifier and Type | Method and Description |
---|---|
protected EventGroup |
EventCorrelator.addEventGroup(EventGroup group) |
MuleEvent |
ResequenceMessagesCorrelatorCallback.aggregateEvents(EventGroup events)
This method is invoked if the shouldAggregate method is called and returns
true.
|
MuleEvent |
ResequenceCorrelatorCallback.aggregateEvents(EventGroup events)
This method is invoked if the shouldAggregate method is called and returns
true.
|
MuleEvent |
EventCorrelatorCallback.aggregateEvents(EventGroup events)
This method is invoked if the shouldAggregate method is called and returns
true.
|
MuleEvent |
CollectionCorrelatorCallback.aggregateEvents(EventGroup events)
This method is invoked if the shouldAggregate method is called and returns true.
|
protected void |
EventCorrelator.handleGroupExpiry(EventGroup group) |
protected void |
EventCorrelator.removeEventGroup(EventGroup group) |
boolean |
EventCorrelatorCallback.shouldAggregateEvents(EventGroup events)
Determines if the event group is ready to be aggregated.
|
boolean |
CollectionCorrelatorCallback.shouldAggregateEvents(EventGroup events) |
Copyright © 2003–2015 MuleSoft, Inc.. All rights reserved.