Package | Description |
---|---|
org.mule.routing |
Defines the core routing patterns supported by mule.
|
org.mule.routing.inbound |
Inbound router implementation as described in the Enterprise Integration Patterns book.
|
org.mule.routing.response |
Response router implementations that enable asynchronous event processing in request /response messaging requests.
|
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 |
SingleCorrelatorCallback.createEventGroup(MuleEvent event,
Object id) |
EventGroup |
CollectionCorrelatorCallback.createEventGroup(MuleEvent event,
Object groupId)
Creates a new EventGroup that will expect the number of events as returned by
MessageAdapter.getCorrelationGroupSize() . |
EventGroup |
AggregationException.getEventGroup() |
protected EventGroup |
EventCorrelator.getEventGroup(Object groupId) |
Modifier and Type | Method and Description |
---|---|
protected EventGroup |
EventCorrelator.addEventGroup(EventGroup group) |
MuleMessage |
EventCorrelatorCallback.aggregateEvents(EventGroup events)
This method is invoked if the shouldAggregate method is called and returns
true.
|
MuleMessage |
SingleCorrelatorCallback.aggregateEvents(EventGroup events)
The
SingleResponseRouter will always return the first event of
an event group. |
MuleMessage |
CollectionCorrelatorCallback.aggregateEvents(EventGroup events)
This method is invoked if the shouldAggregate method is called and returns
true.
|
protected void |
EventCorrelator.removeEventGroup(EventGroup group) |
boolean |
EventCorrelatorCallback.shouldAggregateEvents(EventGroup events)
Determines if the event group is ready to be aggregated.
|
boolean |
SingleCorrelatorCallback.shouldAggregateEvents(EventGroup events)
The
SingleResponseRouter will return true if the event group
size is 1. |
boolean |
CollectionCorrelatorCallback.shouldAggregateEvents(EventGroup events) |
Constructor and Description |
---|
AggregationException(EventGroup eventGroup,
ImmutableEndpoint endpoint) |
AggregationException(EventGroup eventGroup,
ImmutableEndpoint endpoint,
Throwable cause) |
AggregationException(Message message,
EventGroup eventGroup,
ImmutableEndpoint endpoint) |
AggregationException(Message message,
EventGroup eventGroup,
ImmutableEndpoint endpoint,
Throwable cause) |
Modifier and Type | Method and Description |
---|---|
protected EventGroup |
AbstractEventResequencer.addEventGroup(EventGroup group) |
protected EventGroup |
AbstractEventResequencer.createEventGroup(MuleEvent event,
Object groupId) |
protected EventGroup |
AbstractEventResequencer.getEventGroup(Object groupId) |
Modifier and Type | Method and Description |
---|---|
protected EventGroup |
AbstractEventResequencer.addEventGroup(EventGroup group) |
protected abstract MuleMessage |
CorrelationAggregator.aggregateEvents(EventGroup events) |
protected void |
AbstractEventResequencer.removeEventGroup(EventGroup group) |
protected MuleEvent[] |
AbstractEventResequencer.resequenceEvents(EventGroup events)
Reorder collected events according to the configured Comparator.
|
protected abstract boolean |
AbstractEventResequencer.shouldResequenceEvents(EventGroup events)
Determines whether the events in the passed EventGroup are ready to be
reordered.
|
protected boolean |
CorrelationEventResequencer.shouldResequenceEvents(EventGroup events) |
Modifier and Type | Method and Description |
---|---|
EventGroup |
ResponseCorrelationAggregator.DefaultEventCorrelatorCallback.createEventGroup(MuleEvent event,
Object id) |
Modifier and Type | Method and Description |
---|---|
MuleMessage |
ResponseCorrelationAggregator.DefaultEventCorrelatorCallback.aggregateEvents(EventGroup events)
This method is invoked if the shouldAggregate method is called and returns
true.
|
protected MuleMessage |
AbstractResponseAggregator.aggregateEvents(EventGroup events) |
boolean |
ResponseCorrelationAggregator.DefaultEventCorrelatorCallback.shouldAggregateEvents(EventGroup events)
Determines if the event group is ready to be aggregated.
|
Copyright © 2003–2013 MuleSource, Inc.. All rights reserved.