org.apache.camel.component.file.remote
Class FtpConsumer

java.lang.Object
  extended by org.apache.camel.impl.ServiceSupport
      extended by org.apache.camel.impl.DefaultConsumer
          extended by org.apache.camel.impl.ScheduledPollConsumer
              extended by org.apache.camel.component.file.GenericFileConsumer<T>
                  extended by org.apache.camel.component.file.remote.RemoteFileConsumer<org.apache.commons.net.ftp.FTPFile>
                      extended by org.apache.camel.component.file.remote.FtpConsumer
All Implemented Interfaces:
Runnable, BatchConsumer, Consumer, Service, ShutdownAware, SuspendableService

public class FtpConsumer
extends RemoteFileConsumer<org.apache.commons.net.ftp.FTPFile>

FTP consumer


Field Summary
protected  String endpointPath
           
 
Fields inherited from class org.apache.camel.component.file.remote.RemoteFileConsumer
loggedIn
 
Fields inherited from class org.apache.camel.component.file.GenericFileConsumer
endpoint, fileExpressionResult, log, maxMessagesPerPoll, operations, pendingExchanges, shutdownRunningTask
 
Constructor Summary
FtpConsumer(RemoteFileEndpoint<org.apache.commons.net.ftp.FTPFile> endpoint, Processor processor, RemoteFileOperations<org.apache.commons.net.ftp.FTPFile> fileOperations)
           
 
Method Summary
protected  void pollDirectory(String fileName, List<GenericFile<org.apache.commons.net.ftp.FTPFile>> fileList)
          Polls the given directory for files to process
 
Methods inherited from class org.apache.camel.component.file.remote.RemoteFileConsumer
connectIfNecessary, disconnect, doStop, getEndpoint, getOperations, postPollCheck, prePollCheck, remoteServer
 
Methods inherited from class org.apache.camel.component.file.GenericFileConsumer
deferShutdown, doStart, getPendingExchangesSize, isBatchAllowed, isInProgress, isMatched, isValidFile, poll, processBatch, processExchange, setMaxMessagesPerPoll
 
Methods inherited from class org.apache.camel.impl.ScheduledPollConsumer
getDelay, getInitialDelay, getPollStrategy, getTimeUnit, isPollAllowed, isSuspended, isUseFixedDelay, resume, run, setDelay, setInitialDelay, setPollStrategy, setTimeUnit, setUseFixedDelay, suspend
 
Methods inherited from class org.apache.camel.impl.DefaultConsumer
getExceptionHandler, getProcessor, handleException, setExceptionHandler, toString
 
Methods inherited from class org.apache.camel.impl.ServiceSupport
addChildService, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, removeChildService, start, stop
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 
Methods inherited from interface org.apache.camel.Service
start, stop
 

Field Detail

endpointPath

protected String endpointPath
Constructor Detail

FtpConsumer

public FtpConsumer(RemoteFileEndpoint<org.apache.commons.net.ftp.FTPFile> endpoint,
                   Processor processor,
                   RemoteFileOperations<org.apache.commons.net.ftp.FTPFile> fileOperations)
Method Detail

pollDirectory

protected void pollDirectory(String fileName,
                             List<GenericFile<org.apache.commons.net.ftp.FTPFile>> fileList)
Description copied from class: GenericFileConsumer
Polls the given directory for files to process

Specified by:
pollDirectory in class GenericFileConsumer<org.apache.commons.net.ftp.FTPFile>
Parameters:
fileName - current directory or file
fileList - current list of files gathered


Copyright © 2007-2010 IONA Open Source Community. All Rights Reserved.