org.mule.transport.jms
Class XaTransactedJmsMessageReceiver
java.lang.Object
org.mule.transport.AbstractConnectable
org.mule.transport.AbstractMessageReceiver
org.mule.transport.AbstractPollingMessageReceiver
org.mule.transport.TransactedPollingMessageReceiver
org.mule.transport.jms.XaTransactedJmsMessageReceiver
- All Implemented Interfaces:
- ExceptionListener, Disposable, Initialisable, Startable, Stoppable, Connectable, MessageReceiver
- Direct Known Subclasses:
- WebsphereTransactedJmsMessageReceiver
public class XaTransactedJmsMessageReceiver
- extends TransactedPollingMessageReceiver
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, 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 |
DEFAULT_JMS_POLL_FREQUENCY
public static final long DEFAULT_JMS_POLL_FREQUENCY
- See Also:
- Constant Field Values
DEFAULT_JMS_POLL_TIMEUNIT
public static final edu.emory.mathcs.backport.java.util.concurrent.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
redeliveryHandler
protected final RedeliveryHandler redeliveryHandler
XaTransactedJmsMessageReceiver
public XaTransactedJmsMessageReceiver(Connector connector,
Service service,
InboundEndpoint endpoint)
throws CreateException
- Throws:
CreateException
doDispose
protected void doDispose()
- Overrides:
doDispose
in class AbstractConnectable
doConnect
protected void doConnect()
throws Exception
- Overrides:
doConnect
in class AbstractConnectable
- Throws:
Exception
doDisconnect
protected void doDisconnect()
throws Exception
- Overrides:
doDisconnect
in class AbstractConnectable
- 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 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-2009 MuleSource, Inc.. All Rights Reserved.