org.mule.providers
Class PollingMessageReceiver

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

public abstract class PollingMessageReceiver
extends AbstractMessageReceiver
implements java.lang.Runnable

PollingMessageReceiver implements a polling message receiver. The receiver provides a poll method that implementations should implement to execute their custom code. Note that the receiver will not poll if the associated connector is not started.

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

Field Summary
static long DEFAULT_POLL_FREQUENCY
           
static long STARTUP_DELAY
           
 
Fields inherited from class org.mule.providers.AbstractMessageReceiver
component, connector, disposing, endpoint, logger, model, serverSide
 
Constructor Summary
PollingMessageReceiver()
           
PollingMessageReceiver(UMOConnector connector, UMOComponent component, UMOEndpoint endpoint, java.lang.Long frequency)
           
 
Method Summary
protected  void doDispose()
          Template method to dispose any resources associated with this receiver.
 long getFrequency()
           
abstract  void poll()
           
 void run()
           
 void setFrequency(long l)
           
 
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

DEFAULT_POLL_FREQUENCY

public static final long DEFAULT_POLL_FREQUENCY
See Also:
Constant Field Values

STARTUP_DELAY

public static final long STARTUP_DELAY
See Also:
Constant Field Values
Constructor Detail

PollingMessageReceiver

public PollingMessageReceiver()

PollingMessageReceiver

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

run

public void run()
Specified by:
run in interface java.lang.Runnable

setFrequency

public void setFrequency(long l)

getFrequency

public long getFrequency()

doDispose

protected void doDispose()
                  throws UMOException
Description copied from class: AbstractMessageReceiver
Template method to dispose any resources associated with this receiver. There is not need to dispose the connector as this is already done by the framework

Overrides:
doDispose in class AbstractMessageReceiver
Throws:
UMOException

poll

public abstract void poll()
                   throws java.lang.Exception
Throws:
java.lang.Exception


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