org.mule.providers.jms
Class TransactedJmsMessageReceiver

java.lang.Object
  extended byorg.mule.providers.AbstractMessageReceiver
      extended byorg.mule.providers.PollingMessageReceiver
          extended byorg.mule.providers.TransactedPollingMessageReceiver
              extended byorg.mule.providers.jms.TransactedJmsMessageReceiver
All Implemented Interfaces:
Disposable, Lifecycle, Startable, Stoppable, UMOConnectable, UMOMessageReceiver
Direct Known Subclasses:
OracleJmsMessageReceiver

public class TransactedJmsMessageReceiver
extends TransactedPollingMessageReceiver


Nested Class Summary
protected static class TransactedJmsMessageReceiver.JmsThreadContext
          Holder receiving the session and consumer for this thread.
protected static class TransactedJmsMessageReceiver.ThreadContextLocal
          Strongly typed ThreadLocal for ThreadContext.
 
Nested classes inherited from class org.mule.providers.TransactedPollingMessageReceiver
TransactedPollingMessageReceiver.MessageProcessorWorker
 
Field Summary
protected  JmsConnector connector
           
protected  TransactedJmsMessageReceiver.ThreadContextLocal context
           
protected  RedeliveryHandler redeliveryHandler
           
protected  boolean reuseConsumer
           
protected  boolean reuseSession
           
protected  long timeout
           
 
Fields inherited from class org.mule.providers.TransactedPollingMessageReceiver
receiveMessagesInTransaction, useMultipleReceivers
 
Fields inherited from class org.mule.providers.PollingMessageReceiver
DEFAULT_POLL_FREQUENCY, frequency, STARTUP_DELAY
 
Fields inherited from class org.mule.providers.AbstractMessageReceiver
component, connected, connectionStrategy, disposing, endpoint, logger, stopped
 
Constructor Summary
TransactedJmsMessageReceiver(UMOConnector connector, UMOComponent component, UMOEndpoint endpoint)
           
 
Method Summary
protected  void closeConsumer(boolean force)
           
protected  void createConsumer()
          Create a consumer for the jms destination
 void doConnect()
           
 void doDisconnect()
           
protected  List getMessages()
           
 void poll()
          The poll method is overrident from the
protected  void processMessage(Object msg)
           
 
Methods inherited from class org.mule.providers.TransactedPollingMessageReceiver
doStart
 
Methods inherited from class org.mule.providers.PollingMessageReceiver
getFrequency, release, run, setFrequency
 
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
 

Field Detail

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
Constructor Detail

TransactedJmsMessageReceiver

public TransactedJmsMessageReceiver(UMOConnector connector,
                                    UMOComponent component,
                                    UMOEndpoint endpoint)
                             throws InitialisationException
Method Detail

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.