org.openspaces.esb.mule.eventcontainer
Class OpenSpacesMessageDispatcher
java.lang.Object
org.mule.transport.AbstractConnectable
org.mule.transport.AbstractMessageDispatcher
org.openspaces.esb.mule.eventcontainer.OpenSpacesMessageDispatcher
- 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 OpenSpacesMessageDispatcher
- extends org.mule.transport.AbstractMessageDispatcher
OpenSpacesMessageDispatcher
is responsible for sending messages to GigaSpaces space.
- Author:
- yitzhaki
Fields inherited from class org.mule.transport.AbstractConnectable |
connected, connecting, connectionStrategy, connector, 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 |
Method Summary |
protected void |
doConnect()
|
protected void |
doDisconnect()
|
protected void |
doDispatch(org.mule.api.MuleEvent event)
|
protected void |
doDispose()
|
protected org.mule.api.MuleMessage |
doReceive(long timeout)
|
protected org.mule.api.MuleMessage |
doSend(org.mule.api.MuleEvent event)
|
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 |
OpenSpacesMessageDispatcher
public OpenSpacesMessageDispatcher(org.mule.api.endpoint.OutboundEndpoint endpoint)
doDispose
protected void doDispose()
- Specified by:
doDispose
in class org.mule.transport.AbstractConnectable
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
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
doReceive
protected org.mule.api.MuleMessage doReceive(long timeout)
throws Exception
- Throws:
Exception
Copyright © GigaSpaces.