public class VMMessageReceiver extends TransactedPollingMessageReceiver
VMMessageReceiver
is a listener for events from a Mule service which then simply passes
the events on to the target service.Modifier and Type | Class and Description |
---|---|
protected class |
VMMessageReceiver.MessageProcessorWorker |
DEFAULT_POLL_FREQUENCY, DEFAULT_POLL_TIMEUNIT, DEFAULT_STARTUP_DELAY, schedules
defaultInboundTransformers, defaultResponseTransformers, flowConstruct, listener, receiverKey, replyToHandler
connected, defaultMessageInfoMapping, endpoint, lifecycleManager, logger, muleMessageFactory, retryTemplate
PHASE_NAME
PHASE_NAME
PHASE_NAME
PHASE_NAME
Constructor and Description |
---|
VMMessageReceiver(Connector connector,
FlowConstruct flowConstruct,
InboundEndpoint endpoint) |
Modifier and Type | Method and Description |
---|---|
protected PollingReceiverWorker |
createWork() |
protected void |
doConnect() |
protected void |
doDisconnect() |
protected void |
doDispose() |
protected MuleMessage |
getFirstMessage() |
protected List<MuleMessage> |
getFirstMessages() |
protected List<MuleMessage> |
getMessages()
It's impossible to process all messages in the receive transaction
|
protected boolean |
hasNoMessages()
Return true if it can be determined that there are currently no messages to process
|
MuleMessage |
onCall(MuleMessage message) |
void |
onMessage(MuleMessage message) |
protected void |
pollMessagesOutsideTransactions() |
protected MuleEvent |
processMessage(Object msg) |
protected void |
schedule()
This method registers this receiver for periodic polling ticks with the connectors
scheduler.
|
doStart, isReceiveMessagesInTransaction, isUseMultipleTransactedReceivers, poll, setReceiveMessagesInTransaction, setUseMultipleTransactedReceivers
disableNativeScheduling, doStop, getBatchSize, getFrequency, getTimeUnit, performPoll, pollOnPrimaryInstanceOnly, 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
public VMMessageReceiver(Connector connector, FlowConstruct flowConstruct, InboundEndpoint endpoint) throws CreateException
CreateException
protected void schedule() throws RejectedExecutionException, NullPointerException, IllegalArgumentException
AbstractPollingMessageReceiver
protected void doDispose()
doDispose
in class AbstractMessageReceiver
protected void doConnect() throws Exception
doConnect
in class AbstractTransportMessageHandler
Exception
protected void doDisconnect() throws Exception
doDisconnect
in class AbstractTransportMessageHandler
Exception
public void onMessage(MuleMessage message) throws MuleException
MuleException
protected void pollMessagesOutsideTransactions() throws Exception
pollMessagesOutsideTransactions
in class TransactedPollingMessageReceiver
Exception
public MuleMessage onCall(MuleMessage message) throws MuleException
MuleException
protected List<MuleMessage> getMessages() throws Exception
getMessages
in class TransactedPollingMessageReceiver
Exception
protected List<MuleMessage> getFirstMessages() throws Exception
Exception
protected MuleMessage getFirstMessage() throws Exception
Exception
protected boolean hasNoMessages()
TransactedPollingMessageReceiver
hasNoMessages
in class TransactedPollingMessageReceiver
protected MuleEvent processMessage(Object msg) throws Exception
processMessage
in class TransactedPollingMessageReceiver
Exception
protected PollingReceiverWorker createWork()
createWork
in class AbstractPollingMessageReceiver
Copyright © 2003–2018 MuleSoft, Inc.. All rights reserved.