org.mule.samples.voipservice.routers
Class PaymentValidationResponseAggregator

java.lang.Object
  extended byorg.mule.routing.response.AbstractResponseRouter
      extended byorg.mule.routing.response.AbstractResponseAggregator
          extended byorg.mule.routing.response.ResponseCorrelationAggregator
              extended byorg.mule.samples.voipservice.routers.PaymentValidationResponseAggregator
All Implemented Interfaces:
UMOResponseRouter, UMORouter

public class PaymentValidationResponseAggregator
extends ResponseCorrelationAggregator

Author:
Binildas Christudas

Field Summary
protected static Log logger
           
 
Fields inherited from class org.mule.routing.response.AbstractResponseAggregator
eventGroups, responseEvents
 
Fields inherited from class org.mule.routing.response.AbstractResponseRouter
correlationExtractor
 
Constructor Summary
PaymentValidationResponseAggregator()
           
 
Method Summary
protected  UMOMessage aggregateEvents(EventGroup events)
          This method is invoked if the shouldAggregate method is called and returns true.
protected  boolean shouldAggregate(EventGroup events)
          Determines if the event group is ready to be aggregated.
 
Methods inherited from class org.mule.routing.response.ResponseCorrelationAggregator
createEventGroup
 
Methods inherited from class org.mule.routing.response.AbstractResponseAggregator
addEvent, getResponse, process, removeEventGroup
 
Methods inherited from class org.mule.routing.response.AbstractResponseRouter
getCallResponseAggregateIdentifier, getCorrelationExtractor, getReplyAggregateIdentifier, getRouterStatistics, getTimeout, setCorrelationExtractor, setPropertyExtractorAsString, setRouterStatistics, setTimeout
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

logger

protected static transient Log logger
Constructor Detail

PaymentValidationResponseAggregator

public PaymentValidationResponseAggregator()
Method Detail

aggregateEvents

protected UMOMessage aggregateEvents(EventGroup events)
                              throws RoutingException
Description copied from class: AbstractResponseAggregator
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 AbstractResponseAggregator
Parameters:
events - the event group for this request
Returns:
an aggregated message
Throws:
RoutingException - if the aggregation fails. in this scenario the whole event group is removed and passed to the exception handler for this componenet

shouldAggregate

protected boolean shouldAggregate(EventGroup events)
Description copied from class: ResponseCorrelationAggregator
Determines if the event group is ready to be aggregated. if the group is ready to be aggregated (this is entirely up to the application. it could be determined by volume, last modified time or some oher criteria based on the last event received)

Overrides:
shouldAggregate in class ResponseCorrelationAggregator
Parameters:
events -
Returns:
true if the event group is ready of aggregation


Copyright © 2003-2006 MuleSource Inc.. All Rights Reserved.