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, java.lang.Runnable, UMOMessageReceiver

public class JmsMessageReceiver
extends TransactedPollingMessageReceiver

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

Field Summary
 
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()
           
protected  void handleMessageRedelivered(Message message, Session session)
          Process a redelivered message TODO: if messages are redelivered due to a previous transaction rollback, why handle them differently ?
 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, run, setFrequency
 
Methods inherited from class org.mule.providers.AbstractMessageReceiver
allowFilter, create, dispose, getComponent, getConnector, getEndpoint, getEndpointURI, handleException, handleSecurtyException, handleUnacceptedFilter, isServerSide, routeMessage, routeMessage, routeMessage, routeMessage, routeMessage, routeMessage, setComponent, setConnector, setEndpoint, setServerSide
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

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

handleMessageRedelivered

protected void handleMessageRedelivered(Message message,
                                        Session session)
Process a redelivered message TODO: if messages are redelivered due to a previous transaction rollback, why handle them differently ?



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