public class RmiMessageReceiver extends AbstractPollingMessageReceiver
methodArgumentTypes
, If this property is ommitted it is assumed
that the method takes no parametersModifier and Type | Field and Description |
---|---|
protected RmiConnector |
connector |
protected Method |
invokeMethod |
protected Object[] |
methodArguments |
protected Remote |
remoteObject |
DEFAULT_POLL_FREQUENCY, DEFAULT_POLL_TIMEUNIT, DEFAULT_STARTUP_DELAY, schedules
defaultInboundTransformers, defaultResponseTransformers, flowConstruct, listener, receiverKey, replyToHandler
connected, endpoint, lifecycleManager, logger, muleMessageFactory, retryTemplate
PHASE_NAME
PHASE_NAME
PHASE_NAME
PHASE_NAME
Constructor and Description |
---|
RmiMessageReceiver(Connector connector,
FlowConstruct flowConstruct,
InboundEndpoint endpoint,
long frequency) |
Modifier and Type | Method and Description |
---|---|
protected void |
doConnect() |
protected void |
doDisconnect() |
protected void |
doDispose() |
protected Object[] |
getMethodArguments()
Returns the method arguments to use when invoking the method on the Remote
object.
|
void |
poll() |
createWork, disableNativeScheduling, doStart, doStop, getBatchSize, getFrequency, getTimeUnit, performPoll, pollOnPrimaryInstanceOnly, schedule, setFrequency, setTimeUnit, unschedule
applyInboundTransformers, applyResponseTransformers, connectHandler, createExecutionTemplate, createLifecycleManager, createMuleEvent, doStartHandler, 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
protected RmiConnector connector
protected Remote remoteObject
protected Method invokeMethod
protected Object[] methodArguments
public RmiMessageReceiver(Connector connector, FlowConstruct flowConstruct, InboundEndpoint endpoint, long frequency) throws CreateException
CreateException
protected void doDispose()
doDispose
in class AbstractMessageReceiver
protected void doConnect() throws Exception
doConnect
in class AbstractTransportMessageHandler
Exception
protected void doDisconnect()
doDisconnect
in class AbstractTransportMessageHandler
public void poll()
poll
in class AbstractPollingMessageReceiver
protected Object[] getMethodArguments()
Copyright © 2003–2015 MuleSoft, Inc.. All rights reserved.