public abstract class AbstractEventAggregator extends SelectiveConsumer
AbstractEventAggregator
will aggregate a set of messages into a
single message.logger
muleContext
PHASE_NAME
PHASE_NAME
Constructor and Description |
---|
AbstractEventAggregator() |
Modifier and Type | Method and Description |
---|---|
protected abstract EventCorrelatorCallback |
getCorrelatorCallback() |
int |
getTimeout() |
void |
initialise()
Method used to perform any initialisation work.
|
MuleEvent[] |
process(MuleEvent event)
A received MuleEvent is passed to this method for processing.
|
void |
setTimeout(int timeout) |
getFilter, getMessageInfoMapping, isMatch, isTransformFirst, setFilter, setMessageInfoMapping, setTransformFirst
dispose, getMuleContext, getRouterStatistics, setMuleContext, setRouterStatistics
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getRouterStatistics, setRouterStatistics
dispose
public void initialise() throws InitialisationException
Initialisable
InitialisationException
should be thrown,
causing the Mule instance to shutdown. If the error is recoverable, say by
retrying to connect, a RecoverableException
should be thrown.
There is no guarantee that by throwing a Recoverable exception that the Mule
instance will not shut down.initialise
in interface Initialisable
initialise
in class AbstractRouter
InitialisationException
- if a fatal error occurs causing the Mule instance to shutdownRecoverableException
- if an error occurs that can be recovered fromprotected abstract EventCorrelatorCallback getCorrelatorCallback()
public MuleEvent[] process(MuleEvent event) throws MessagingException
InboundRouter
process
in interface InboundRouter
process
in class SelectiveConsumer
event
- the event received by the inbound endpoint before it is passed to
the serviceMessagingException
- if an error occurs during processing of the eventpublic int getTimeout()
public void setTimeout(int timeout)
Copyright © 2003–2013 MuleSource, Inc.. All rights reserved.