public class RmiCallbackMessageReceiver extends AbstractMessageReceiver
Modifier and Type | Field and Description |
---|---|
protected RmiConnector |
connector |
static String |
PROPERTY_SERVICE_CLASS_NAME
The property name for the service object implementing the callback interface
RmiAble This should be set on the inbound endpoint
|
protected RmiAble |
remoteObject |
defaultInboundTransformers, defaultResponseTransformers, flowConstruct, listener, receiverKey, replyToHandler
connected, endpoint, lifecycleManager, logger, muleMessageFactory, retryTemplate
PHASE_NAME
PHASE_NAME
PHASE_NAME
PHASE_NAME
Constructor and Description |
---|
RmiCallbackMessageReceiver(Connector connector,
FlowConstruct flowConstruct,
InboundEndpoint endpoint) |
Modifier and Type | Method and Description |
---|---|
protected void |
doConnect()
Initializes endpoint
|
protected void |
doDisconnect()
Unbinds Rmi class from registry
|
protected void |
doDispose() |
protected void |
doStart() |
MuleEvent |
routeMessage(Object payload) |
applyInboundTransformers, applyResponseTransformers, connectHandler, createExecutionTemplate, createLifecycleManager, createMuleEvent, doStartHandler, doStop, getConnectEventId, getConnectionDescription, getEndpoint, getEndpointURI, getFlowConstruct, getReceiverKey, getReplyToHandler, getWorkManager, handleUnacceptedFilter, initialise, processMessage, propagateRootMessageIdProperty, routeEvent, routeMessage, routeMessage, routeMessage, routeMessage, routeMessage, setEndpoint, setListener, setReceiverKey, shouldConsumeInEveryNode, toString, warnIfMuleClientSendUsed
activate, connect, createMuleMessage, createMuleMessage, createMuleMessage, createMuleMessageFactory, createNullMuleMessage, disconnect, dispose, disposeAndLogException, doInitialise, getConnectEventId, getConnector, getLifecycleState, initializeMessageFactory, initializeRetryPolicy, isConnected, isDoThreading, isStarted, isStarting, isStopped, isStopping, passivate, setEndpoint, start, stop, validate, validateConnection
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
createMuleMessage, createMuleMessage
connect, disconnect, isConnected, validateConnection
dispose
public static final String PROPERTY_SERVICE_CLASS_NAME
protected RmiConnector connector
protected RmiAble remoteObject
public RmiCallbackMessageReceiver(Connector connector, FlowConstruct flowConstruct, InboundEndpoint endpoint) throws CreateException
CreateException
protected void doDispose()
doDispose
in class AbstractMessageReceiver
protected void doConnect() throws ConnectException
doConnect
in class AbstractTransportMessageHandler
ConnectException
protected void doDisconnect()
doDisconnect
in class AbstractTransportMessageHandler
protected void doStart() throws MuleException
doStart
in class AbstractTransportMessageHandler
MuleException
public MuleEvent routeMessage(Object payload) throws MuleException
MuleException
Copyright © 2003–2015 MuleSoft, Inc.. All rights reserved.