org.apache.camel.component.file.remote
Class SftpConsumer
java.lang.Object
org.apache.camel.impl.ServiceSupport
org.apache.camel.impl.DefaultConsumer<E>
org.apache.camel.impl.ScheduledPollConsumer<T>
org.apache.camel.component.file.remote.RemoteFileConsumer<RemoteFileExchange>
org.apache.camel.component.file.remote.SftpConsumer
- All Implemented Interfaces:
- Runnable, org.apache.camel.Consumer<RemoteFileExchange>, org.apache.camel.Service
public class SftpConsumer
- extends RemoteFileConsumer<RemoteFileExchange>
Methods inherited from class org.apache.camel.impl.ScheduledPollConsumer |
doStart, doStop, getDelay, getInitialDelay, getTimeUnit, isUseFixedDelay, run, setDelay, setInitialDelay, setTimeUnit, setUseFixedDelay |
Methods inherited from class org.apache.camel.impl.DefaultConsumer |
getEndpoint, getExceptionHandler, getProcessor, handleException, setExceptionHandler, toString |
Methods inherited from class org.apache.camel.impl.ServiceSupport |
isStarted, isStopped, isStopping, start, stop |
Methods inherited from interface org.apache.camel.Service |
start, stop |
SftpConsumer
public SftpConsumer(SftpEndpoint endpoint,
org.apache.camel.Processor processor,
com.jcraft.jsch.ChannelSftp channel)
SftpConsumer
public SftpConsumer(SftpEndpoint endpoint,
org.apache.camel.Processor processor,
com.jcraft.jsch.ChannelSftp channel,
ScheduledExecutorService executor)
poll
protected void poll()
throws Exception
- Specified by:
poll
in class org.apache.camel.impl.ScheduledPollConsumer<RemoteFileExchange>
- Throws:
Exception
pollDirectory
protected void pollDirectory(String dir)
throws Exception
- Throws:
Exception
getFullFileName
protected String getFullFileName(com.jcraft.jsch.ChannelSftp.LsEntry sftpFile)
throws IOException
- Throws:
IOException
isMatched
protected boolean isMatched(com.jcraft.jsch.ChannelSftp.LsEntry sftpFile)
isRecursive
public boolean isRecursive()
setRecursive
public void setRecursive(boolean recursive)
getLastPollTime
public long getLastPollTime()
setLastPollTime
public void setLastPollTime(long lastPollTime)
getRegexPattern
public String getRegexPattern()
setRegexPattern
public void setRegexPattern(String regexPattern)
Copyright © 2007 Apache Software Foundation. All Rights Reserved.