org.mule.tck.testmodels.mule
Class TestCorrelationAggregator

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.tck.testmodels.mule.TestCorrelationAggregator
All Implemented Interfaces:
AnnotatedObject, FlowConstructAware, MuleContextAware, Initialisable, Startable, Stoppable, InterceptingMessageProcessor, MessageProcessor, Aggregator, MessageSource

public class TestCorrelationAggregator
extends AbstractCorrelationAggregator

TestResponseAggregator is a mock response Agrregator object used for testing configuration


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
TestCorrelationAggregator()
           
 
Method Summary
protected  MuleEvent aggregateEvents(EventGroup events)
           
 String getTestProperty()
           
 void setTestProperty(String testProperty)
           
 
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

TestCorrelationAggregator

public TestCorrelationAggregator()
Method Detail

aggregateEvents

protected MuleEvent aggregateEvents(EventGroup events)
                             throws AggregationException
Specified by:
aggregateEvents in class AbstractCorrelationAggregator
Throws:
AggregationException

getTestProperty

public String getTestProperty()

setTestProperty

public void setTestProperty(String testProperty)


Copyright © 2003-2012 MuleSoft, Inc.. All Rights Reserved.