org.mule.transport
Class TransactedPollingMessageReceiver
java.lang.Object
org.mule.transport.AbstractConnectable
org.mule.transport.AbstractMessageReceiver
org.mule.transport.AbstractPollingMessageReceiver
org.mule.transport.TransactedPollingMessageReceiver
- All Implemented Interfaces:
- ExceptionListener, Disposable, Initialisable, Startable, Stoppable, 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 improveded throuput.
Methods inherited from class org.mule.transport.AbstractMessageReceiver |
dispose, getConnectEventId, getConnectionDescription, getEndpoint, getEndpointURI, getListener, getReceiverKey, getService, getWorkManager, handleUnacceptedFilter, initialise, routeMessage, routeMessage, routeMessage, routeMessage, routeMessage, routeMessage, setEndpoint, setExceptionDetails, setListener, setReceiverKey, setService, toString |
Methods inherited from class org.mule.transport.AbstractConnectable |
activate, connect, disconnect, disposeAndLogException, doConnect, doDisconnect, doDispose, doInitialise, exceptionThrown, getConnectEventId, getConnector, handleException, isConnected, isDoThreading, isStarted, 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,
Service service,
InboundEndpoint endpoint)
throws CreateException
- Throws:
CreateException
TransactedPollingMessageReceiver
public TransactedPollingMessageReceiver(Connector connector,
Service service,
InboundEndpoint endpoint,
long frequency)
throws CreateException
- Deprecated. please use
#TransactedPollingMessageReceiver(Connector,Service,InboundEndpoint,long,TimeUnit)
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
getMessages
protected abstract List getMessages()
throws Exception
- Throws:
Exception
processMessage
protected abstract void processMessage(Object message)
throws Exception
- Throws:
Exception
Copyright © 2003-2009 MuleSource, Inc.. All Rights Reserved.