org.mule.providers.ftp
Class FtpMessageReceiver

java.lang.Object
  org.mule.providers.AbstractMessageReceiver
      org.mule.providers.AbstractPollingMessageReceiver
          org.mule.providers.ftp.FtpMessageReceiver

All Implemented Interfaces:

Disposable, Lifecycle, Startable, Stoppable, UMOConnectable, UMOMessageReceiver

public class FtpMessageReceiver

extends AbstractPollingMessageReceiver

Field Summary

protected FtpConnector	connector
protected Set	currentFiles
protected FilenameFilter	filenameFilter
protected Set	scheduledFiles

Fields inherited from class org.mule.providers.AbstractPollingMessageReceiver

DEFAULT_POLL_FREQUENCY, DEFAULT_POLL_TIMEUNIT, DEFAULT_STARTUP_DELAY, schedules

Fields inherited from class org.mule.providers.AbstractMessageReceiver

component, connected, connecting, connectionStrategy, disposing, endpoint, logger, receiverKey, stopped

Constructor Summary

FtpMessageReceiver(UMOConnector connector, UMOComponent component, UMOEndpoint endpoint, long frequency)

Method Summary

protected void	doConnect()
protected void	doDisconnect()
protected void	doDispose()
protected org.apache.commons.net.ftp.FTPFile[]	listFiles()
void	poll()
protected void	processFile(org.apache.commons.net.ftp.FTPFile file)

Methods inherited from class org.mule.providers.AbstractPollingMessageReceiver

createWork, doStart, doStop, getFrequency, getTimeUnit, setFrequency, setTimeUnit

Methods inherited from class org.mule.providers.AbstractMessageReceiver

applyResponseTransformer, connect, disconnect, dispose, getComponent, getConnectEventId, getConnectionDescription, getConnector, getEndpoint, getEndpointURI, getListener, getReceiverKey, getWorkManager, handleException, handleUnacceptedFilter, isConnected, routeMessage, routeMessage, routeMessage, routeMessage, routeMessage, routeMessage, setComponent, setConnector, setEndpoint, setExceptionDetails, setListener, setReceiverKey, setWorkManager, start, stop, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

connector

protected final FtpConnector connector

filenameFilter

protected final FilenameFilter filenameFilter

scheduledFiles

protected final Set scheduledFiles

currentFiles

protected final Set currentFiles

Constructor Detail

FtpMessageReceiver

public FtpMessageReceiver(UMOConnector connector,
                          UMOComponent component,
                          UMOEndpoint endpoint,
                          long frequency)
                   throws InitialisationException

Method Detail

poll

public void poll()
          throws Exception

Specified by:

poll in class AbstractPollingMessageReceiver

Throws:

Exception

listFiles

protected org.apache.commons.net.ftp.FTPFile[] listFiles()
                                                  throws Exception

Throws:

Exception

processFile

protected void processFile(org.apache.commons.net.ftp.FTPFile file)
                    throws Exception

Throws:

Exception

doConnect

protected void doConnect()
                  throws Exception

Specified by:

doConnect in class AbstractMessageReceiver

Throws:

Exception

doDisconnect

protected void doDisconnect()
                     throws Exception

Specified by:

doDisconnect in class AbstractMessageReceiver

Throws:

Exception

doDispose

protected void doDispose()

Specified by:

doDispose in class AbstractMessageReceiver