|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.mule.transport.AbstractTransportMessageHandler
org.mule.transport.AbstractMessageDispatcher
org.mule.transport.amqp.internal.endpoint.dispatcher.Dispatcher
public class Dispatcher
The Dispatcher
takes care of sending messages from Mule to an AMQP
broker. It supports synchronous sending by the means of private temporary reply queues.
Field Summary | |
---|---|
protected AmqpConnector |
amqpConnector
|
Fields inherited from class org.mule.transport.AbstractMessageDispatcher |
---|
defaultOutboundTransformers, defaultResponseTransformers |
Fields inherited from class org.mule.transport.AbstractTransportMessageHandler |
---|
connected, connector, endpoint, lifecycleManager, logger, muleMessageFactory, retryTemplate |
Fields inherited from interface org.mule.api.transport.MessageDispatcher |
---|
RECEIVE_NO_WAIT, RECEIVE_WAIT_INDEFINITELY |
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.lifecycle.Disposable |
---|
PHASE_NAME |
Constructor Summary | |
---|---|
Dispatcher(org.mule.api.endpoint.OutboundEndpoint endpoint)
|
Method Summary | |
---|---|
protected void |
addReturnListenerIfNeeded(org.mule.api.MuleEvent event,
com.rabbitmq.client.Channel channel)
Try to associate a return listener to the channel in order to allow flow-level exception strategy to handle return messages. |
void |
doDispatch(org.mule.api.MuleEvent event)
|
protected void |
doDispose()
|
protected void |
doInitialise()
|
protected AmqpMessage |
doOutboundAction(org.mule.api.MuleEvent event,
DispatcherAction outboundAction)
|
org.mule.api.MuleMessage |
doSend(org.mule.api.MuleEvent event)
|
Methods inherited from class org.mule.transport.AbstractMessageDispatcher |
---|
applyOutboundTransformers, applyResponseTransformers, createLifecycleManager, getDispatcherName, getEndpoint, getWorkManager, process, returnResponse, returnResponse |
Methods inherited from class org.mule.transport.AbstractTransportMessageHandler |
---|
activate, connect, connectHandler, createMuleMessage, createMuleMessage, createMuleMessage, createMuleMessageFactory, createNullMuleMessage, disconnect, dispose, disposeAndLogException, doConnect, doDisconnect, doStart, doStartHandler, doStop, getConnectEventId, getConnectionDescription, getConnector, getLifecycleState, initialise, initializeMessageFactory, initializeRetryPolicy, isConnected, isDoThreading, isStarted, isStarting, isStopped, isStopping, passivate, setEndpoint, start, stop, toString, validate, validateConnection |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Methods inherited from interface org.mule.api.transport.MessageDispatcher |
---|
activate, createMuleMessage, createMuleMessage, getConnector, passivate, validate |
Methods inherited from interface org.mule.api.transport.Connectable |
---|
connect, disconnect, getConnectionDescription, isConnected, validateConnection |
Methods inherited from interface org.mule.api.lifecycle.Initialisable |
---|
initialise |
Methods inherited from interface org.mule.api.lifecycle.Startable |
---|
start |
Methods inherited from interface org.mule.api.lifecycle.Stoppable |
---|
stop |
Methods inherited from interface org.mule.api.lifecycle.Disposable |
---|
dispose |
Methods inherited from interface org.mule.api.lifecycle.LifecycleStateEnabled |
---|
getLifecycleState |
Field Detail |
---|
protected final AmqpConnector amqpConnector
Constructor Detail |
---|
public Dispatcher(org.mule.api.endpoint.OutboundEndpoint endpoint)
Method Detail |
---|
protected void doInitialise() throws org.mule.api.lifecycle.InitialisationException
doInitialise
in class org.mule.transport.AbstractTransportMessageHandler
org.mule.api.lifecycle.InitialisationException
protected void doDispose()
doDispose
in class org.mule.transport.AbstractTransportMessageHandler
public void doDispatch(org.mule.api.MuleEvent event) throws Exception
doDispatch
in class org.mule.transport.AbstractMessageDispatcher
Exception
public org.mule.api.MuleMessage doSend(org.mule.api.MuleEvent event) throws Exception
doSend
in class org.mule.transport.AbstractMessageDispatcher
Exception
protected AmqpMessage doOutboundAction(org.mule.api.MuleEvent event, DispatcherAction outboundAction) throws Exception
Exception
protected void addReturnListenerIfNeeded(org.mule.api.MuleEvent event, com.rabbitmq.client.Channel channel)
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |