public interface MessageDispatcher extends Connectable, MessageProcessor, LifecycleStateEnabled
MessageDispatching
with
various lifecycle methods for the actual instances doing message sending.Modifier and Type | Field and Description |
---|---|
static long |
RECEIVE_NO_WAIT |
static long |
RECEIVE_WAIT_INDEFINITELY |
PHASE_NAME
PHASE_NAME
PHASE_NAME
PHASE_NAME
Modifier and Type | Method and Description |
---|---|
void |
activate()
This method can perform necessary state updates before any of the
MessageDispatching methods are invoked. |
MuleMessage |
createMuleMessage(Object transportMessage) |
MuleMessage |
createMuleMessage(Object transportMessage,
String encoding) |
Connector |
getConnector()
Gets the connector for this dispatcher
|
OutboundEndpoint |
getEndpoint() |
void |
passivate()
After sending a message, the dispatcher can use this method e.g.
|
boolean |
validate()
Determines whether this dispatcher can be reused after message sending.
|
connect, disconnect, getConnectionDescription, isConnected, validateConnection
initialise
dispose
process
getLifecycleState
static final long RECEIVE_WAIT_INDEFINITELY
static final long RECEIVE_NO_WAIT
void activate()
MessageDispatching
methods are invoked.void passivate()
activate()
.boolean validate()
true
if this dispatcher can be reused,
false
otherwise (for example when
Disposable.dispose()
has been called because an Exception was
raised)Connector getConnector()
OutboundEndpoint getEndpoint()
MuleMessage createMuleMessage(Object transportMessage, String encoding) throws MuleException
MuleException
MuleMessage createMuleMessage(Object transportMessage) throws MuleException
MuleException
Copyright © 2003–2015 MuleSoft, Inc.. All rights reserved.