org.mule.transport.jms
Class XaTransactedJmsMessageReceiver
java.lang.Object
org.mule.transport.AbstractTransportMessageHandler
org.mule.transport.AbstractMessageReceiver
org.mule.transport.AbstractPollingMessageReceiver
org.mule.transport.TransactedPollingMessageReceiver
org.mule.transport.jms.XaTransactedJmsMessageReceiver
- All Implemented Interfaces:
- Disposable, Initialisable, Lifecycle, LifecycleStateEnabled, Startable, Stoppable, MessageSource, Connectable, MessageReceiver
- Direct Known Subclasses:
- WebsphereTransactedJmsMessageReceiver
public class XaTransactedJmsMessageReceiver
- extends TransactedPollingMessageReceiver
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, 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, 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 |
DEFAULT_JMS_POLL_FREQUENCY
public static final long DEFAULT_JMS_POLL_FREQUENCY
- See Also:
- Constant Field Values
DEFAULT_JMS_POLL_TIMEUNIT
public static final TimeUnit DEFAULT_JMS_POLL_TIMEUNIT
connector
protected final JmsConnector connector
reuseConsumer
protected boolean reuseConsumer
reuseSession
protected boolean reuseSession
context
protected final XaTransactedJmsMessageReceiver.ThreadContextLocal context
timeout
protected final long timeout
XaTransactedJmsMessageReceiver
public XaTransactedJmsMessageReceiver(Connector connector,
FlowConstruct flowConstruct,
InboundEndpoint endpoint)
throws CreateException
- Throws:
CreateException
doDispose
protected void doDispose()
- Overrides:
doDispose
in class AbstractMessageReceiver
doConnect
protected void doConnect()
throws Exception
- Overrides:
doConnect
in class AbstractTransportMessageHandler
- Throws:
Exception
doDisconnect
protected void doDisconnect()
throws Exception
- Overrides:
doDisconnect
in class AbstractTransportMessageHandler
- Throws:
Exception
poll
public void poll()
throws Exception
- The poll method is overriden from the
TransactedPollingMessageReceiver
- Overrides:
poll
in class TransactedPollingMessageReceiver
- Throws:
Exception
getMessages
protected List<MuleMessage> getMessages()
throws Exception
- Specified by:
getMessages
in class TransactedPollingMessageReceiver
- Throws:
Exception
processMessage
protected void processMessage(Object msg)
throws Exception
- Specified by:
processMessage
in class TransactedPollingMessageReceiver
- Throws:
Exception
closeResource
protected void closeResource(boolean force)
- Close Sesison and consumer
createConsumer
protected MessageConsumer createConsumer()
throws Exception
- Create a consumer for the jms destination
- Throws:
Exception
Copyright © 2003-2012 MuleSoft, Inc.. All Rights Reserved.