org.mule.example.loanbroker.routers
Class BankQuotesInboundAggregator

java.lang.Object
  extended by org.mule.processor.AbstractInterceptingMessageProcessorBase
      extended by org.mule.processor.AbstractInterceptingMessageProcessor
          extended by org.mule.routing.AbstractAggregator
              extended by org.mule.routing.AbstractCorrelationAggregator
                  extended by 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


Field Summary
 
Fields inherited from class org.mule.routing.AbstractAggregator
eventCorrelator, flowConstruct, messageInfoMapping, muleContext, persistentStores, storePrefix
 
Fields inherited from class org.mule.processor.AbstractInterceptingMessageProcessorBase
logger, next, notificationHandler
 
Fields inherited from interface org.mule.api.lifecycle.Initialisable
PHASE_NAME
 
Fields inherited from interface org.mule.api.lifecycle.Startable
PHASE_NAME
 
Fields inherited from interface org.mule.api.lifecycle.Stoppable
PHASE_NAME
 
Fields inherited from interface org.mule.api.AnnotatedObject
PROPERTY_NAME
 
Constructor Summary
BankQuotesInboundAggregator()
           
 
Method Summary
protected  MuleEvent aggregateEvents(EventGroup events)
          This method is invoked if the shouldAggregate method is called and returns true.
 
Methods inherited from class org.mule.routing.AbstractCorrelationAggregator
getCorrelatorCallback
 
Methods inherited from class org.mule.routing.AbstractAggregator
expireAggregation, getStorePrefix, getTimeout, initialise, isFailOnTimeout, isPersistentStores, process, setFailOnTimeout, setFlowConstruct, setMessageInfoMapping, setMuleContext, setPersistentStores, setStorePrefix, setTimeout, start, stop
 
Methods inherited from class org.mule.processor.AbstractInterceptingMessageProcessorBase
getAnnotation, getAnnotations, getListener, getMuleContext, isEventValid, processNext, setAnnotations, setListener, toString
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 
Methods inherited from interface org.mule.api.source.MessageSource
setListener
 

Constructor Detail

BankQuotesInboundAggregator

public BankQuotesInboundAggregator()
Method Detail

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.