public class FtpStreamingMessageSource extends AbstractRemoteFileStreamingMessageSource<org.apache.commons.net.ftp.FTPFile>
IntegrationManagement.ManagementOverrides
EXPRESSION_PARSER, logger
METER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME
Constructor and Description |
---|
FtpStreamingMessageSource(RemoteFileTemplate<org.apache.commons.net.ftp.FTPFile> template)
Construct an instance with the supplied template.
|
FtpStreamingMessageSource(RemoteFileTemplate<org.apache.commons.net.ftp.FTPFile> template,
java.util.Comparator<org.apache.commons.net.ftp.FTPFile> comparator)
Construct an instance with the supplied template and comparator.
|
Modifier and Type | Method and Description |
---|---|
protected java.util.List<AbstractFileInfo<org.apache.commons.net.ftp.FTPFile>> |
asFileInfoList(java.util.Collection<org.apache.commons.net.ftp.FTPFile> files) |
java.lang.String |
getComponentType() |
protected boolean |
isDirectory(org.apache.commons.net.ftp.FTPFile file) |
doInit, doReceive, doReceive, doSetFilter, getRemoteFileTemplate, onInit, poll, remotePath, rollbackFromFileToListEnd, setFileInfoJson, setFilter, setRemoteDirectory, setRemoteDirectoryExpression, setRemoteFileSeparator
getMaxFetchSize, setMaxFetchSize
buildMessage, destroy, getComponentName, getManagedName, getManagedType, getMessageCount, getMessageCountLong, getOverrides, isCountsEnabled, isLoggingEnabled, receive, registerMetricsCaptor, reset, setBeanName, setCountsEnabled, setHeaderExpressions, setLoggingEnabled, setManagedName, setManagedType
afterPropertiesSet, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, getBeanFactory, getEvaluationContext, getEvaluationContext, getMessageBuilderFactory, setBeanFactory, setConversionService
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
afterPropertiesSet
getManagedName, getManagedType, getMessageCount, getMessageCountLong, setManagedName, setManagedType
getOverrides, isCountsEnabled, isLoggingEnabled, registerMetricsCaptor, reset, setCountsEnabled, setLoggingEnabled
public FtpStreamingMessageSource(RemoteFileTemplate<org.apache.commons.net.ftp.FTPFile> template)
template
- the template.public FtpStreamingMessageSource(RemoteFileTemplate<org.apache.commons.net.ftp.FTPFile> template, java.util.Comparator<org.apache.commons.net.ftp.FTPFile> comparator)
template
- the template.comparator
- the comparator.public java.lang.String getComponentType()
protected java.util.List<AbstractFileInfo<org.apache.commons.net.ftp.FTPFile>> asFileInfoList(java.util.Collection<org.apache.commons.net.ftp.FTPFile> files)
asFileInfoList
in class AbstractRemoteFileStreamingMessageSource<org.apache.commons.net.ftp.FTPFile>
protected boolean isDirectory(org.apache.commons.net.ftp.FTPFile file)
isDirectory
in class AbstractRemoteFileStreamingMessageSource<org.apache.commons.net.ftp.FTPFile>