public abstract class AbstractMessageDispatcher extends AbstractTransportMessageHandler implements MessageDispatcher
Modifier and Type | Field and Description |
---|---|
protected List<Transformer> |
defaultOutboundTransformers |
protected List<Transformer> |
defaultResponseTransformers |
connected, connector, defaultMessageInfoMapping, 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 void |
doSendNonBlocking(MuleEvent event,
CompletionHandler<MuleMessage,Exception> completionHandler) |
protected String |
getDispatcherName() |
OutboundEndpoint |
getEndpoint() |
protected WorkManager |
getWorkManager() |
protected boolean |
isSupportsNonBlocking()
Dispatcher implementations that support non-blocking processing should override this method and return 'true'.
|
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
protected boolean isSupportsNonBlocking()
doSendNonBlocking(MuleEvent, CompletionHandler)
method.@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
protected void doSendNonBlocking(MuleEvent event, CompletionHandler<MuleMessage,Exception> completionHandler)
Copyright © 2003–2016 MuleSoft, Inc.. All rights reserved.