org.mule.providers
Class TransactedPollingMessageReceiver

java.lang.Object
  extended byorg.mule.providers.AbstractMessageReceiver
      extended byorg.mule.providers.PollingMessageReceiver
          extended byorg.mule.providers.TransactedPollingMessageReceiver
All Implemented Interfaces:
Disposable, java.lang.Runnable, UMOMessageReceiver
Direct Known Subclasses:
JdbcMessageReceiver, JmsMessageReceiver

public abstract class TransactedPollingMessageReceiver
extends PollingMessageReceiver

Version:
$Revision: 1.1 $
Author:
Guillaume Nodet

Field Summary
protected  boolean receiveMessagesInTransaction
           
 
Fields inherited from class org.mule.providers.PollingMessageReceiver
DEFAULT_POLL_FREQUENCY, STARTUP_DELAY
 
Fields inherited from class org.mule.providers.AbstractMessageReceiver
component, connector, disposing, endpoint, logger, model, serverSide
 
Constructor Summary
TransactedPollingMessageReceiver()
           
TransactedPollingMessageReceiver(UMOConnector connector, UMOComponent component, UMOEndpoint endpoint, java.lang.Long frequency)
           
 
Method Summary
protected abstract  java.util.List getMessages()
           
 void poll()
           
protected abstract  void processMessage(java.lang.Object message)
           
 
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
 

Field Detail

receiveMessagesInTransaction

protected boolean receiveMessagesInTransaction
Constructor Detail

TransactedPollingMessageReceiver

public TransactedPollingMessageReceiver()

TransactedPollingMessageReceiver

public TransactedPollingMessageReceiver(UMOConnector connector,
                                        UMOComponent component,
                                        UMOEndpoint endpoint,
                                        java.lang.Long frequency)
                                 throws InitialisationException
Method Detail

poll

public void poll()
          throws java.lang.Exception
Specified by:
poll in class PollingMessageReceiver
Throws:
java.lang.Exception

getMessages

protected abstract java.util.List getMessages()
                                       throws java.lang.Exception
Throws:
java.lang.Exception

processMessage

protected abstract void processMessage(java.lang.Object message)
                                throws java.lang.Exception
Throws:
java.lang.Exception


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