org.mule.transport

Class TransactedPollingMessageReceiver

java.lang.Object

org.mule.transport.AbstractMessageReceiver

org.mule.transport.AbstractPollingMessageReceiver

org.mule.transport.TransactedPollingMessageReceiver

All Implemented Interfaces:

Disposable, Initialisable, Lifecycle, Startable, Stoppable, Connectable, MessageReceiver

Direct Known Subclasses:

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.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	TransactedPollingMessageReceiver.MessageProcessorWorker

Field Summary

Fields inherited from class org.mule.transport.AbstractPollingMessageReceiver

DEFAULT_POLL_FREQUENCY, DEFAULT_POLL_TIMEUNIT, DEFAULT_STARTUP_DELAY, schedules

Fields inherited from class org.mule.transport.AbstractMessageReceiver

connected, connecting, connectionStrategy, connector, disposing, endpoint, logger, receiverKey, responseEndpoint, service, stopped

Fields inherited from interface org.mule.api.lifecycle.Initialisable

PHASE_NAME

Fields inherited from interface org.mule.api.lifecycle.Startable

PHASE_NAME

Fields inherited from interface org.mule.api.lifecycle.Stoppable

PHASE_NAME

Fields inherited from interface org.mule.api.lifecycle.Disposable

PHASE_NAME

Constructor Summary

Constructors

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

Method Summary

Methods

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)

Methods inherited from class org.mule.transport.AbstractPollingMessageReceiver

createWork, doStop, getFrequency, getTimeUnit, schedule, setFrequency, setTimeUnit, unschedule

Methods inherited from class org.mule.transport.AbstractMessageReceiver

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

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

Method Detail

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