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
connected, connecting, connectionStrategy, connector, disposing, endpoint, logger, receiverKey, responseEndpoint, service, stopped
PHASE_NAME
PHASE_NAME
PHASE_NAME
PHASE_NAME
Constructor and Description |
---|
TransactedPollingMessageReceiver(Connector connector,
Service service,
InboundEndpoint endpoint) |
TransactedPollingMessageReceiver(Connector connector,
Service service,
InboundEndpoint endpoint,
long frequency)
Deprecated.
please use
#TransactedPollingMessageReceiver(Connector,Service,InboundEndpoint,long,TimeUnit)
instead |
Modifier and Type | Method and Description |
---|---|
void |
doStart() |
protected abstract List |
getMessages() |
boolean |
isReceiveMessagesInTransaction() |
boolean |
isUseMultipleTransactedReceivers() |
void |
poll() |
protected abstract void |
processMessage(Object message) |
void |
setReceiveMessagesInTransaction(boolean useTx) |
void |
setUseMultipleTransactedReceivers(boolean useMultiple) |
createWork, doStop, getFrequency, getTimeUnit, schedule, setFrequency, setTimeUnit, unschedule
connect, disconnect, dispose, doConnect, doDisconnect, doDispose, doInitialise, getConnectEventId, getConnectionDescription, getConnector, getEndpoint, getEndpointURI, getListener, getReceiverKey, getService, getWorkManager, handleException, handleUnacceptedFilter, initialise, isConnected, routeMessage, routeMessage, routeMessage, routeMessage, routeMessage, routeMessage, setConnector, setEndpoint, setExceptionDetails, setListener, setReceiverKey, setService, setWorkManager, start, stop, toString
public TransactedPollingMessageReceiver(Connector connector, Service service, InboundEndpoint endpoint) throws CreateException
CreateException
public TransactedPollingMessageReceiver(Connector connector, Service service, InboundEndpoint endpoint, long frequency) throws CreateException
#TransactedPollingMessageReceiver(Connector,Service,InboundEndpoint,long,TimeUnit)
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
Copyright © 2003–2013 MuleSource, Inc.. All rights reserved.