org.openspaces.esb.mule.queue
Class OpenSpacesQueueMessageDispatcher
java.lang.Object
org.mule.transport.AbstractConnectable
org.mule.transport.AbstractMessageDispatcher
org.openspaces.esb.mule.queue.OpenSpacesQueueMessageDispatcher
- All Implemented Interfaces:
- ExceptionListener, org.mule.api.lifecycle.Disposable, org.mule.api.transport.Connectable, org.mule.api.transport.MessageDispatcher, org.mule.api.transport.MessageDispatching
public class OpenSpacesQueueMessageDispatcher
- extends org.mule.transport.AbstractMessageDispatcher
Dispatches (writes) a message to an intenral queue. The queue is a virtualized queue represented
by the InternalQueueEntry
with its endpoint address
set (and not the message).
- Author:
- kimchy
Fields inherited from class org.mule.transport.AbstractConnectable |
connected, connecting, connectionStrategy, disposed, endpoint, logger, workManager |
Fields inherited from interface org.mule.api.lifecycle.Disposable |
PHASE_NAME |
Fields inherited from interface org.mule.api.transport.MessageDispatching |
RECEIVE_NO_WAIT, RECEIVE_WAIT_INDEFINITELY |
Methods inherited from class org.mule.transport.AbstractMessageDispatcher |
dispatch, isTransactionRollback, send, useRemoteSync |
Methods inherited from class org.mule.transport.AbstractConnectable |
activate, connect, disconnect, dispose, disposeAndLogException, exceptionThrown, getConnectEventId, getConnectionDescription, getConnector, getEndpoint, isConnected, isDoThreading, passivate, reconnect, toString, validate |
Methods inherited from interface org.mule.api.transport.MessageDispatcher |
activate, getConnector, passivate, validate |
Methods inherited from interface org.mule.api.lifecycle.Disposable |
dispose |
Methods inherited from interface org.mule.api.transport.Connectable |
connect, disconnect, getConnectionDescription, isConnected |
OpenSpacesQueueMessageDispatcher
public OpenSpacesQueueMessageDispatcher(org.mule.api.endpoint.OutboundEndpoint endpoint)
doDispatch
protected void doDispatch(org.mule.api.MuleEvent event)
throws Exception
- Specified by:
doDispatch
in class org.mule.transport.AbstractMessageDispatcher
- Throws:
Exception
doSend
protected org.mule.api.MuleMessage doSend(org.mule.api.MuleEvent event)
throws Exception
- Specified by:
doSend
in class org.mule.transport.AbstractMessageDispatcher
- Throws:
Exception
doDispose
protected void doDispose()
- Specified by:
doDispose
in class org.mule.transport.AbstractConnectable
doConnect
protected void doConnect()
throws Exception
- Specified by:
doConnect
in class org.mule.transport.AbstractConnectable
- Throws:
Exception
doDisconnect
protected void doDisconnect()
throws Exception
- Specified by:
doDisconnect
in class org.mule.transport.AbstractConnectable
- Throws:
Exception
Copyright © GigaSpaces.