public class XaTransactedJmsMessageReceiver extends TransactedPollingMessageReceiver
Modifier and Type | Class and Description |
---|---|
protected static class |
XaTransactedJmsMessageReceiver.JmsThreadContext
Holder receiving the session and consumer for this thread.
|
protected static class |
XaTransactedJmsMessageReceiver.ThreadContextLocal
Strongly typed ThreadLocal for ThreadContext.
|
TransactedPollingMessageReceiver.MessageProcessorWorker
Modifier and Type | Field and Description |
---|---|
protected JmsConnector |
connector |
protected XaTransactedJmsMessageReceiver.ThreadContextLocal |
context |
static long |
DEFAULT_JMS_POLL_FREQUENCY |
static TimeUnit |
DEFAULT_JMS_POLL_TIMEUNIT |
protected RedeliveryHandler |
redeliveryHandler |
protected boolean |
reuseConsumer |
protected boolean |
reuseSession |
protected long |
timeout |
DEFAULT_POLL_FREQUENCY, DEFAULT_POLL_TIMEUNIT, DEFAULT_STARTUP_DELAY, schedules
connected, connecting, connectionStrategy, disposing, endpoint, logger, receiverKey, responseEndpoint, service, stopped
PHASE_NAME
PHASE_NAME
PHASE_NAME
PHASE_NAME
Constructor and Description |
---|
XaTransactedJmsMessageReceiver(Connector umoConnector,
Service service,
InboundEndpoint endpoint) |
Modifier and Type | Method and Description |
---|---|
protected void |
closeResource(boolean force)
Close Sesison and consumer
|
protected javax.jms.MessageConsumer |
createConsumer()
Create a consumer for the jms destination
|
protected void |
doConnect() |
protected void |
doDisconnect() |
protected void |
doDispose() |
protected List |
getMessages() |
void |
poll()
The poll method is overriden from the
TransactedPollingMessageReceiver |
protected void |
processMessage(Object msg) |
doStart, isReceiveMessagesInTransaction, isUseMultipleTransactedReceivers, setReceiveMessagesInTransaction, setUseMultipleTransactedReceivers
createWork, doStop, getFrequency, getTimeUnit, schedule, setFrequency, setTimeUnit, unschedule
connect, disconnect, dispose, 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 static final long DEFAULT_JMS_POLL_FREQUENCY
public static final TimeUnit DEFAULT_JMS_POLL_TIMEUNIT
protected final JmsConnector connector
protected boolean reuseConsumer
protected boolean reuseSession
protected final XaTransactedJmsMessageReceiver.ThreadContextLocal context
protected final long timeout
protected final RedeliveryHandler redeliveryHandler
public XaTransactedJmsMessageReceiver(Connector umoConnector, Service service, InboundEndpoint endpoint) throws CreateException
CreateException
protected void doDispose()
doDispose
in class AbstractMessageReceiver
protected void doConnect() throws Exception
doConnect
in class AbstractMessageReceiver
Exception
protected void doDisconnect() throws Exception
doDisconnect
in class AbstractMessageReceiver
Exception
public void poll() throws Exception
TransactedPollingMessageReceiver
poll
in class TransactedPollingMessageReceiver
Exception
protected List getMessages() throws Exception
getMessages
in class TransactedPollingMessageReceiver
Exception
protected void processMessage(Object msg) throws Exception
processMessage
in class TransactedPollingMessageReceiver
Exception
protected void closeResource(boolean force)
Copyright © 2003–2013 MuleSource, Inc.. All rights reserved.