public abstract class AbstractMessageDispatcher extends AbstractTransportMessageHandler implements MessageDispatcher
Modifier and Type | Field and Description |
---|---|
protected List<Transformer> |
defaultOutboundTransformers |
protected List<Transformer> |
defaultResponseTransformers |
connected, connector, endpoint, lifecycleManager, logger, muleMessageFactory, retryTemplate
RECEIVE_NO_WAIT, RECEIVE_WAIT_INDEFINITELY
PHASE_NAME
PHASE_NAME
PHASE_NAME
PHASE_NAME
Constructor and Description |
---|
AbstractMessageDispatcher(OutboundEndpoint endpoint) |
Modifier and Type | Method and Description |
---|---|
protected void |
applyOutboundTransformers(MuleEvent event) |
protected void |
applyResponseTransformers(MuleEvent event) |
protected ConnectableLifecycleManager |
createLifecycleManager() |
protected abstract void |
doDispatch(MuleEvent event) |
protected abstract MuleMessage |
doSend(MuleEvent event) |
protected String |
getDispatcherName() |
OutboundEndpoint |
getEndpoint() |
protected WorkManager |
getWorkManager() |
MuleEvent |
process(MuleEvent event)
Invokes the MessageProcessor.
|
protected boolean |
returnResponse(MuleEvent event)
Deprecated.
|
protected boolean |
returnResponse(MuleEvent event,
boolean doSend)
Used to determine if the dispatcher implementation should wait for a response to an event on a response
channel after it sends the event.
|
activate, connect, connectHandler, createMuleMessage, createMuleMessage, createMuleMessage, createMuleMessageFactory, createNullMuleMessage, disconnect, dispose, disposeAndLogException, doConnect, doDisconnect, doDispose, doInitialise, doStart, doStartHandler, doStop, getConnectEventId, getConnectionDescription, getConnector, getLifecycleState, initialise, initializeMessageFactory, initializeRetryPolicy, isConnected, isDoThreading, isStarted, isStarting, isStopped, isStopping, passivate, setEndpoint, start, stop, toString, validate, validateConnection
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
activate, createMuleMessage, createMuleMessage, getConnector, passivate, validate
connect, disconnect, getConnectionDescription, isConnected, validateConnection
initialise
dispose
getLifecycleState
protected List<Transformer> defaultOutboundTransformers
protected List<Transformer> defaultResponseTransformers
public AbstractMessageDispatcher(OutboundEndpoint endpoint)
protected ConnectableLifecycleManager createLifecycleManager()
createLifecycleManager
in class AbstractTransportMessageHandler
protected String getDispatcherName()
public MuleEvent process(MuleEvent event) throws MuleException
MessageProcessor
process
in interface MessageProcessor
event
- MuleEvent to be processedMuleException
@Deprecated protected boolean returnResponse(MuleEvent event)
protected boolean returnResponse(MuleEvent event, boolean doSend)
event
- the current eventprotected WorkManager getWorkManager()
getWorkManager
in class AbstractTransportMessageHandler
public OutboundEndpoint getEndpoint()
getEndpoint
in interface MessageDispatcher
getEndpoint
in class AbstractTransportMessageHandler
protected void applyOutboundTransformers(MuleEvent event) throws MuleException
MuleException
protected void applyResponseTransformers(MuleEvent event) throws MuleException
MuleException
protected abstract MuleMessage doSend(MuleEvent event) throws Exception
Exception
Copyright © 2003–2015 MuleSoft, Inc.. All rights reserved.