org.mule.providers.jms
Class TransactedJmsMessageReceiver
java.lang.Object
org.mule.providers.AbstractMessageReceiver
org.mule.providers.PollingMessageReceiver
org.mule.providers.TransactedPollingMessageReceiver
org.mule.providers.jms.TransactedJmsMessageReceiver
- All Implemented Interfaces:
- Disposable, Lifecycle, Startable, Stoppable, UMOConnectable, UMOMessageReceiver
- Direct Known Subclasses:
- OracleJmsMessageReceiver
- public class TransactedJmsMessageReceiver
- extends TransactedPollingMessageReceiver
| Methods inherited from class org.mule.providers.AbstractMessageReceiver |
applyResponseTransformer, connect, disconnect, dispose, doDispose, doStop, getComponent, getConnectEventId, getConnectionDescription, getConnector, getEndpoint, getEndpointURI, getListener, getWorkManager, handleException, handleUnacceptedFilter, isConnected, routeMessage, routeMessage, routeMessage, routeMessage, routeMessage, routeMessage, setComponent, setConnector, setEndpoint, setExceptionDetails, setListener, setWorkManager, start, stop |
| Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
connector
protected final JmsConnector connector
reuseConsumer
protected boolean reuseConsumer
reuseSession
protected boolean reuseSession
context
protected final TransactedJmsMessageReceiver.ThreadContextLocal context
timeout
protected final long timeout
redeliveryHandler
protected final RedeliveryHandler redeliveryHandler
TransactedJmsMessageReceiver
public TransactedJmsMessageReceiver(UMOConnector connector,
UMOComponent component,
UMOEndpoint endpoint)
throws InitialisationException
doConnect
public void doConnect()
throws Exception
- Specified by:
doConnect in class AbstractMessageReceiver
- Throws:
Exception
doDisconnect
public void doDisconnect()
throws Exception
- Specified by:
doDisconnect in class AbstractMessageReceiver
- Throws:
Exception
poll
public void poll()
throws Exception
- The poll method is overrident from the
- 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
closeConsumer
protected void closeConsumer(boolean force)
createConsumer
protected void createConsumer()
throws Exception
- Create a consumer for the jms destination
- Throws:
Exception
Copyright © 2003-2006 MuleSource Inc.. All Rights Reserved.