org.mule.providers.jms
Class JmsMessageReceiver

java.lang.Object
  extended byorg.mule.providers.AbstractMessageReceiver
      extended byorg.mule.providers.PollingMessageReceiver
          extended byorg.mule.providers.TransactedPollingMessageReceiver
              extended byorg.mule.providers.jms.JmsMessageReceiver
All Implemented Interfaces:
Disposable, UMOMessageReceiver

public class JmsMessageReceiver
extends TransactedPollingMessageReceiver

Version:
$Revision: 1.11 $
Author:
Ross Mason, Guillaume Nodet

Field Summary
protected  JmsConnector connector
           
protected  MessageConsumer consumer
           
protected  long frequency
           
protected  RedeliveryHandler redeliveryHandler
           
protected  boolean reuseConsumer
           
protected  boolean reuseSession
           
protected  Session session
           
 
Fields inherited from class org.mule.providers.TransactedPollingMessageReceiver
receiveMessagesInTransaction
 
Fields inherited from class org.mule.providers.PollingMessageReceiver
DEFAULT_POLL_FREQUENCY, STARTUP_DELAY
 
Fields inherited from class org.mule.providers.AbstractMessageReceiver
component, disposing, endpoint, logger, model, serverSide
 
Constructor Summary
JmsMessageReceiver()
           
JmsMessageReceiver(UMOConnector connector, UMOComponent component, UMOEndpoint endpoint)
           
 
Method Summary
protected  void closeConsumer()
           
protected  void createConsumer()
          Create a consumer for the jms destination
protected  java.util.List getMessages()
           
 void poll()
          The poll method is overrident from the
protected  void processMessage(java.lang.Object msg)
           
 
Methods inherited from class org.mule.providers.PollingMessageReceiver
doDispose, getFrequency, release, run, setFrequency
 
Methods inherited from class org.mule.providers.AbstractMessageReceiver
allowFilter, create, dispose, getComponent, getConnector, getEndpoint, getEndpointURI, getWorkManager, handleException, handleUnacceptedFilter, isServerSide, routeMessage, routeMessage, routeMessage, routeMessage, routeMessage, routeMessage, setComponent, setConnector, setEndpoint, setServerSide, setWorkManager
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

connector

protected JmsConnector connector

reuseConsumer

protected boolean reuseConsumer

reuseSession

protected boolean reuseSession

session

protected Session session

consumer

protected MessageConsumer consumer

frequency

protected long frequency

redeliveryHandler

protected RedeliveryHandler redeliveryHandler
Constructor Detail

JmsMessageReceiver

public JmsMessageReceiver()

JmsMessageReceiver

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

poll

public void poll()
          throws java.lang.Exception
The poll method is overrident from the

Overrides:
poll in class TransactedPollingMessageReceiver
Throws:
java.lang.Exception

getMessages

protected java.util.List getMessages()
                              throws java.lang.Exception
Specified by:
getMessages in class TransactedPollingMessageReceiver
Throws:
java.lang.Exception

processMessage

protected void processMessage(java.lang.Object msg)
                       throws java.lang.Exception
Specified by:
processMessage in class TransactedPollingMessageReceiver
Throws:
java.lang.Exception

closeConsumer

protected void closeConsumer()

createConsumer

protected void createConsumer()
                       throws java.lang.Exception
Create a consumer for the jms destination

Throws:
java.lang.Exception


Copyright © 2003-2005 SymphonySoft Limited. All Rights Reserved.