org.mule.transport
Class TransactedPollingMessageReceiver
java.lang.Object
org.mule.transport.AbstractTransportMessageHandler
org.mule.transport.AbstractMessageReceiver
org.mule.transport.AbstractPollingMessageReceiver
org.mule.transport.TransactedPollingMessageReceiver
- All Implemented Interfaces:
- Disposable, Initialisable, Lifecycle, LifecycleStateEnabled, Startable, Stoppable, MessageSource, Connectable, MessageReceiver
- Direct Known Subclasses:
- JdbcMessageReceiver, VMMessageReceiver, XaTransactedJmsMessageReceiver
public abstract class TransactedPollingMessageReceiver
- extends AbstractPollingMessageReceiver
The TransactedPollingMessageReceiver is an abstract receiver that handles polling
and transaction management. Derived implementations of these class must be thread
safe as several threads can be started at once for an improved throughput.
Methods inherited from class org.mule.transport.AbstractPollingMessageReceiver |
createWork, disableNativeScheduling, doStop, getBatchSize, getFrequency, getTimeUnit, performPoll, pollOnPrimaryInstanceOnly, schedule, setFrequency, setTimeUnit, unschedule |
Methods inherited from class org.mule.transport.AbstractMessageReceiver |
applyInboundTransformers, applyResponseTransformers, createExecutionTemplate, createLifecycleManager, createMuleEvent, doDispose, getConnectEventId, getConnectionDescription, getEndpoint, getEndpointURI, getFlowConstruct, getReceiverKey, getReplyToHandler, getWorkManager, handleUnacceptedFilter, initialise, propagateRootMessageIdProperty, routeMessage, routeMessage, routeMessage, routeMessage, routeMessage, setEndpoint, setListener, setReceiverKey, toString, warnIfMuleClientSendUsed |
Methods inherited from class org.mule.transport.AbstractTransportMessageHandler |
activate, connect, createMuleMessage, createMuleMessage, createMuleMessage, createMuleMessageFactory, createNullMuleMessage, disconnect, dispose, disposeAndLogException, doConnect, doDisconnect, doInitialise, getConnectEventId, getConnector, getLifecycleState, initializeMessageFactory, initializeRetryPolicy, isConnected, isDoThreading, isStarted, isStarting, isStopping, passivate, setEndpoint, start, stop, validate, validateConnection |
Methods inherited from interface org.mule.api.lifecycle.Startable |
start |
Methods inherited from interface org.mule.api.lifecycle.Stoppable |
stop |
TransactedPollingMessageReceiver
public TransactedPollingMessageReceiver(Connector connector,
FlowConstruct flowConstruct,
InboundEndpoint endpoint)
throws CreateException
- Throws:
CreateException
TransactedPollingMessageReceiver
@Deprecated
public TransactedPollingMessageReceiver(Connector connector,
FlowConstruct flowConstruct,
InboundEndpoint endpoint,
long frequency)
throws CreateException
- Deprecated. please use
TransactedPollingMessageReceiver(Connector, FlowConstruct, InboundEndpoint)
instead
- Throws:
CreateException
isReceiveMessagesInTransaction
public boolean isReceiveMessagesInTransaction()
setReceiveMessagesInTransaction
public void setReceiveMessagesInTransaction(boolean useTx)
isUseMultipleTransactedReceivers
public boolean isUseMultipleTransactedReceivers()
setUseMultipleTransactedReceivers
public void setUseMultipleTransactedReceivers(boolean useMultiple)
doStart
public void doStart()
throws MuleException
- Overrides:
doStart
in class AbstractPollingMessageReceiver
- Throws:
MuleException
poll
public void poll()
throws Exception
- Specified by:
poll
in class AbstractPollingMessageReceiver
- Throws:
Exception
hasNoMessages
protected boolean hasNoMessages()
- Return true if it can be determined that there are currently no messages to process
getMessages
protected abstract List<MuleMessage> getMessages()
throws Exception
- Throws:
Exception
processMessage
protected abstract void processMessage(Object message)
throws Exception
- Throws:
Exception
Copyright © 2003-2012 MuleSoft, Inc.. All Rights Reserved.