public abstract class AbstractRemoteFileStreamingMessageSource<F>
extends org.springframework.integration.endpoint.AbstractMessageSource<java.io.InputStream>
implements org.springframework.context.Lifecycle
InputStream payload
referencing a remote file.| Modifier | Constructor and Description |
|---|---|
protected |
AbstractRemoteFileStreamingMessageSource(RemoteFileTemplate<F> template,
java.util.Comparator<AbstractFileInfo<F>> comparator) |
| Modifier and Type | Method and Description |
|---|---|
void |
afterPropertiesSet() |
protected abstract java.util.List<AbstractFileInfo<F>> |
asFileInfoList(java.util.Collection<F> files) |
protected void |
doInit()
Subclasses can override to perform initialization - called from
InitializingBean.afterPropertiesSet(). |
protected java.lang.Object |
doReceive() |
protected void |
doSetFilter(FileListFilter<F> filterToSet) |
protected RemoteFileTemplate<F> |
getRemoteFileTemplate() |
boolean |
isRunning() |
protected AbstractFileInfo<F> |
poll() |
protected java.lang.String |
remotePath(AbstractFileInfo<F> file) |
void |
setFilter(FileListFilter<F> filter)
Set the filter to be applied to the remote files before transferring.
|
void |
setRemoteDirectory(java.lang.String remoteDirectory)
Specify the full path to the remote directory.
|
void |
setRemoteDirectoryExpression(org.springframework.expression.Expression remoteDirectoryExpression)
Specify an expression that evaluates to the full path to the remote directory.
|
void |
setRemoteFileSeparator(java.lang.String remoteFileSeparator)
Set the remote file separator; default '/'
|
void |
start() |
void |
stop() |
getComponentName, getManagedName, getManagedType, getMessageCount, getMessageCountLong, isCountsEnabled, isLoggingEnabled, receive, reset, setBeanName, setCountsEnabled, setHeaderExpressions, setLoggingEnabled, setManagedName, setManagedTypeevaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, getBeanFactory, getEvaluationContext, getEvaluationContext, getMessageBuilderFactory, setBeanFactory, setConversionServiceprotected AbstractRemoteFileStreamingMessageSource(RemoteFileTemplate<F> template, java.util.Comparator<AbstractFileInfo<F>> comparator)
public void setRemoteDirectory(java.lang.String remoteDirectory)
remoteDirectory - The remote directory.public void setRemoteDirectoryExpression(org.springframework.expression.Expression remoteDirectoryExpression)
remoteDirectoryExpression - The remote directory expression.public void setRemoteFileSeparator(java.lang.String remoteFileSeparator)
remoteFileSeparator - the remote file separator.public void setFilter(FileListFilter<F> filter)
filter - the file list filter.protected final void doSetFilter(FileListFilter<F> filterToSet)
protected RemoteFileTemplate<F> getRemoteFileTemplate()
public final void afterPropertiesSet()
afterPropertiesSet in interface org.springframework.beans.factory.InitializingBeanafterPropertiesSet in class org.springframework.integration.util.AbstractExpressionEvaluatorprotected void doInit()
InitializingBean.afterPropertiesSet().public void start()
start in interface org.springframework.context.Lifecyclepublic void stop()
stop in interface org.springframework.context.Lifecyclepublic boolean isRunning()
isRunning in interface org.springframework.context.Lifecycleprotected java.lang.Object doReceive()
doReceive in class org.springframework.integration.endpoint.AbstractMessageSource<java.io.InputStream>protected AbstractFileInfo<F> poll()
protected java.lang.String remotePath(AbstractFileInfo<F> file)
protected abstract java.util.List<AbstractFileInfo<F>> asFileInfoList(java.util.Collection<F> files)