org.mule.providers
Class PollingMessageReceiver

java.lang.Object
  extended byorg.mule.providers.AbstractMessageReceiver
      extended byorg.mule.providers.PollingMessageReceiver
All Implemented Interfaces:
Disposable, Lifecycle, Startable, Stoppable, UMOConnectable, UMOMessageReceiver
Direct Known Subclasses:
DQMessageReceiver, FileMessageReceiver, FtpMessageReceiver, PollingHttpMessageReceiver, Pop3MessageReceiver, RmiMessageReceiver, StreamMessageReceiver, TcpStreamingMessageReceiver, TransactedPollingMessageReceiver

public abstract class PollingMessageReceiver
extends AbstractMessageReceiver

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.


Field Summary
static long DEFAULT_POLL_FREQUENCY
           
protected  long frequency
           
static long STARTUP_DELAY
           
 
Fields inherited from class org.mule.providers.AbstractMessageReceiver
component, connected, connectionStrategy, connector, disposing, endpoint, logger, stopped
 
Constructor Summary
PollingMessageReceiver(UMOConnector connector, UMOComponent component, UMOEndpoint endpoint, Long frequency)
           
 
Method Summary
 void doStart()
           
 long getFrequency()
           
abstract  void poll()
           
 void release()
           
 void run()
           
 void setFrequency(long l)
           
 
Methods inherited from class org.mule.providers.AbstractMessageReceiver
applyResponseTransformer, connect, disconnect, dispose, doConnect, doDisconnect, 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

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

frequency

protected long frequency
Constructor Detail

PollingMessageReceiver

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

doStart

public void doStart()
             throws UMOException
Overrides:
doStart in class AbstractMessageReceiver
Throws:
UMOException

run

public void run()

release

public void release()

setFrequency

public void setFrequency(long l)

getFrequency

public long getFrequency()

poll

public abstract void poll()
                   throws Exception
Throws:
Exception


Copyright © 2003-2006 MuleSource Inc.. All Rights Reserved.