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

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<com.jcraft.jsch.ChannelSftp.LsEntry>
                      extended by org.apache.camel.component.file.remote.SftpConsumer
All Implemented Interfaces:
Runnable, BatchConsumer, Consumer, Service, ShutdownableService, ShutdownAware, SuspendableService

public class SftpConsumer
extends RemoteFileConsumer<com.jcraft.jsch.ChannelSftp.LsEntry>

Secure FTP consumer


Field Summary
 
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
SftpConsumer(RemoteFileEndpoint<com.jcraft.jsch.ChannelSftp.LsEntry> endpoint, Processor processor, RemoteFileOperations<com.jcraft.jsch.ChannelSftp.LsEntry> operations)
           
 
Method Summary
protected  boolean doPollDirectory(String absolutePath, String dirName, List<GenericFile<com.jcraft.jsch.ChannelSftp.LsEntry>> fileList)
           
protected  boolean pollDirectory(String fileName, List<GenericFile<com.jcraft.jsch.ChannelSftp.LsEntry>> fileList)
          Polls the given directory for files to process
protected  boolean pollSubDirectory(String absolutePath, String dirName, List<GenericFile<com.jcraft.jsch.ChannelSftp.LsEntry>> fileList)
           
 
Methods inherited from class org.apache.camel.component.file.remote.RemoteFileConsumer
connectIfNecessary, disconnect, doStop, getEndpoint, getOperations, postPollCheck, prePollCheck, recoverableConnectIfNecessary, remoteServer
 
Methods inherited from class org.apache.camel.component.file.GenericFileConsumer
canPollMoreFiles, deferShutdown, doStart, getPendingExchangesSize, isBatchAllowed, isInProgress, isMatched, isValidFile, poll, processBatch, processExchange, setMaxMessagesPerPoll, setOperations
 
Methods inherited from class org.apache.camel.impl.ScheduledPollConsumer
doSuspend, getDelay, getInitialDelay, getPollStrategy, getTimeUnit, isPollAllowed, isUseFixedDelay, run, setDelay, setInitialDelay, setPollStrategy, setTimeUnit, setUseFixedDelay
 
Methods inherited from class org.apache.camel.impl.DefaultConsumer
getAsyncProcessor, getExceptionHandler, getProcessor, handleException, setExceptionHandler, toString
 
Methods inherited from class org.apache.camel.impl.ServiceSupport
addChildService, doResume, doShutdown, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isSuspended, isSuspending, removeChildService, resume, shutdown, start, start, stop, suspend
 
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
 
Methods inherited from interface org.apache.camel.SuspendableService
isSuspended, resume, suspend
 

Constructor Detail

SftpConsumer

public SftpConsumer(RemoteFileEndpoint<com.jcraft.jsch.ChannelSftp.LsEntry> endpoint,
                    Processor processor,
                    RemoteFileOperations<com.jcraft.jsch.ChannelSftp.LsEntry> operations)
Method Detail

pollDirectory

protected boolean pollDirectory(String fileName,
                                List<GenericFile<com.jcraft.jsch.ChannelSftp.LsEntry>> fileList)
Description copied from class: GenericFileConsumer
Polls the given directory for files to process

Specified by:
pollDirectory in class GenericFileConsumer<com.jcraft.jsch.ChannelSftp.LsEntry>
Parameters:
fileName - current directory or file
fileList - current list of files gathered
Returns:
whether or not to continue polling, false means the maxMessagesPerPoll limit has been hit

pollSubDirectory

protected boolean pollSubDirectory(String absolutePath,
                                   String dirName,
                                   List<GenericFile<com.jcraft.jsch.ChannelSftp.LsEntry>> fileList)

doPollDirectory

protected boolean doPollDirectory(String absolutePath,
                                  String dirName,
                                  List<GenericFile<com.jcraft.jsch.ChannelSftp.LsEntry>> fileList)


Apache CAMEL