public abstract class TransactedPollingMessageReceiver extends AbstractPollingMessageReceiver
Modifier and Type | Class and Description |
---|---|
protected class |
TransactedPollingMessageReceiver.MessageProcessorWorker |
DEFAULT_POLL_FREQUENCY, DEFAULT_POLL_TIMEUNIT, DEFAULT_STARTUP_DELAY, schedules
defaultInboundTransformers, defaultResponseTransformers, flowConstruct, listener, receiverKey, replyToHandler
connected, connector, endpoint, lifecycleManager, logger, muleMessageFactory, retryTemplate
PHASE_NAME
PHASE_NAME
PHASE_NAME
PHASE_NAME
Constructor and Description |
---|
TransactedPollingMessageReceiver(Connector connector,
FlowConstruct flowConstruct,
InboundEndpoint endpoint) |
TransactedPollingMessageReceiver(Connector connector,
FlowConstruct flowConstruct,
InboundEndpoint endpoint,
long frequency)
Deprecated.
please use
TransactedPollingMessageReceiver(Connector, FlowConstruct, InboundEndpoint)
instead |
Modifier and Type | Method and Description |
---|---|
void |
doStart() |
protected abstract List<MuleMessage> |
getMessages() |
protected boolean |
hasNoMessages()
Return true if it can be determined that there are currently no messages to process
|
boolean |
isReceiveMessagesInTransaction() |
boolean |
isUseMultipleTransactedReceivers() |
void |
poll() |
protected abstract void |
processMessage(Object message) |
void |
setReceiveMessagesInTransaction(boolean useTx) |
void |
setUseMultipleTransactedReceivers(boolean useMultiple) |
createWork, disableNativeScheduling, doStop, getBatchSize, getFrequency, getTimeUnit, performPoll, pollOnPrimaryInstanceOnly, schedule, setFrequency, setTimeUnit, unschedule
applyInboundTransformers, applyResponseTransformers, connectHandler, createExecutionTemplate, createLifecycleManager, createMuleEvent, doDispose, 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, doConnect, doDisconnect, 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 TransactedPollingMessageReceiver(Connector connector, FlowConstruct flowConstruct, InboundEndpoint endpoint) throws CreateException
CreateException
@Deprecated public TransactedPollingMessageReceiver(Connector connector, FlowConstruct flowConstruct, InboundEndpoint endpoint, long frequency) throws CreateException
TransactedPollingMessageReceiver(Connector, FlowConstruct, InboundEndpoint)
insteadCreateException
public boolean isReceiveMessagesInTransaction()
public void setReceiveMessagesInTransaction(boolean useTx)
public boolean isUseMultipleTransactedReceivers()
public void setUseMultipleTransactedReceivers(boolean useMultiple)
public void doStart() throws MuleException
doStart
in class AbstractPollingMessageReceiver
MuleException
public void poll() throws Exception
poll
in class AbstractPollingMessageReceiver
Exception
protected boolean hasNoMessages()
protected abstract List<MuleMessage> getMessages() throws Exception
Exception
Copyright © 2003–2015 MuleSoft, Inc.. All rights reserved.