org.mule.example.loanbroker.routers
Class BankQuotesInboundAggregator
java.lang.Object
org.mule.processor.AbstractInterceptingMessageProcessorBase
org.mule.processor.AbstractInterceptingMessageProcessor
org.mule.routing.AbstractAggregator
org.mule.routing.AbstractCorrelationAggregator
org.mule.example.loanbroker.routers.BankQuotesInboundAggregator
- All Implemented Interfaces:
- AnnotatedObject, FlowConstructAware, MuleContextAware, Initialisable, Startable, Stoppable, InterceptingMessageProcessor, MessageProcessor, Aggregator, MessageSource
public class BankQuotesInboundAggregator
- extends AbstractCorrelationAggregator
BankQuotesInboundAggregator
receives a number of quotes and selects the
lowest
Methods inherited from class org.mule.routing.AbstractAggregator |
expireAggregation, getStorePrefix, getTimeout, initialise, isFailOnTimeout, isPersistentStores, process, setFailOnTimeout, setFlowConstruct, setMessageInfoMapping, setMuleContext, setPersistentStores, setStorePrefix, setTimeout, start, stop |
BankQuotesInboundAggregator
public BankQuotesInboundAggregator()
aggregateEvents
protected MuleEvent aggregateEvents(EventGroup events)
throws AggregationException
- This method is invoked if the shouldAggregate method is called and returns
true. Once this method returns an aggregated message the event group is
removed from the router
- Specified by:
aggregateEvents
in class AbstractCorrelationAggregator
- Parameters:
events
- the event group for this request
- Returns:
- an aggregated message
- Throws:
AggregationException
- if the aggregation fails. in this scenario the
whole event group is removed and passed to the exception handler
for this componenet
Copyright © 2003-2012 MuleSoft, Inc.. All Rights Reserved.