org.springframework.integration.file.remote

Class AbstractRemoteFileStreamingMessageSource<F>

java.lang.Object

org.springframework.integration.util.AbstractExpressionEvaluator

org.springframework.integration.endpoint.AbstractMessageSource<T>

org.springframework.integration.endpoint.AbstractFetchLimitingMessageSource<InputStream>

org.springframework.integration.file.remote.AbstractRemoteFileStreamingMessageSource<F>

All Implemented Interfaces:

Aware, BeanFactoryAware, BeanNameAware, InitializingBean, MessageSource<InputStream>, MessageSourceManagement, NamedComponent, IntegrationManagement, MessageSourceMetrics

Direct Known Subclasses:

FtpStreamingMessageSource, SftpStreamingMessageSource

public abstract class AbstractRemoteFileStreamingMessageSource<F>
extends AbstractFetchLimitingMessageSource<InputStream>
implements BeanFactoryAware, InitializingBean

A message source that produces a message with an InputStream payload referencing a remote file.

Since:

4.3

Author:

Gary Russell, Artem Bilan

Field Summary

Fields inherited from class org.springframework.integration.util.AbstractExpressionEvaluator

EXPRESSION_PARSER, logger

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractRemoteFileStreamingMessageSource(RemoteFileTemplate<F> template, Comparator<AbstractFileInfo<F>> comparator)

Method Summary

Modifier and Type	Method and Description
void	afterPropertiesSet()
protected abstract List<AbstractFileInfo<F>>	asFileInfoList(Collection<F> files)
protected void	doInit() Subclasses can override to perform initialization - called from InitializingBean.afterPropertiesSet().
protected Object	doReceive() Subclasses must implement this method.
protected Object	doReceive(int maxFetchSize) Subclasses must implement this method.
protected void	doSetFilter(FileListFilter<F> filter)
protected RemoteFileTemplate<F>	getRemoteFileTemplate()
protected AbstractFileInfo<F>	poll()
protected String	remotePath(AbstractFileInfo<F> file)
protected void	rollbackFromFileToListEnd(List<F> filteredFiles, F file)
void	setFileInfoJson(boolean fileInfoJson) Set to false to add the FileHeaders.REMOTE_FILE_INFO header to the raw FileInfo.
void	setFilter(FileListFilter<F> filter) Set the filter to be applied to the remote files before transferring.
void	setRemoteDirectory(String remoteDirectory) Specify the full path to the remote directory.
void	setRemoteDirectoryExpression(Expression remoteDirectoryExpression) Specify an expression that evaluates to the full path to the remote directory.
void	setRemoteFileSeparator(String remoteFileSeparator) Set the remote file separator; default '/'

Methods inherited from class org.springframework.integration.endpoint.AbstractFetchLimitingMessageSource

getMaxFetchSize, setMaxFetchSize

Methods inherited from class org.springframework.integration.endpoint.AbstractMessageSource

buildMessage, getComponentName, getManagedName, getManagedType, getMessageCount, getMessageCountLong, isCountsEnabled, isLoggingEnabled, receive, reset, setBeanName, setCountsEnabled, setHeaderExpressions, setLoggingEnabled, setManagedName, setManagedType

Methods inherited from class org.springframework.integration.util.AbstractExpressionEvaluator

evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, getBeanFactory, getEvaluationContext, getEvaluationContext, getMessageBuilderFactory, setBeanFactory, setConversionService

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.springframework.beans.factory.BeanFactoryAware

setBeanFactory

Methods inherited from interface org.springframework.integration.support.management.MessageSourceMetrics

getManagedName, getManagedType, getMessageCount, getMessageCountLong, setManagedName, setManagedType

Methods inherited from interface org.springframework.integration.support.management.IntegrationManagement

isCountsEnabled, isLoggingEnabled, reset, setCountsEnabled, setLoggingEnabled

Methods inherited from interface org.springframework.integration.support.context.NamedComponent

getComponentType

Constructor Detail

AbstractRemoteFileStreamingMessageSource

protected AbstractRemoteFileStreamingMessageSource(RemoteFileTemplate<F> template,
                                                   Comparator<AbstractFileInfo<F>> comparator)

Method Detail

setRemoteDirectory

public void setRemoteDirectory(String remoteDirectory)

Specify the full path to the remote directory.

Parameters:

remoteDirectory - The remote directory.

setRemoteDirectoryExpression

public void setRemoteDirectoryExpression(Expression remoteDirectoryExpression)

Specify an expression that evaluates to the full path to the remote directory.

Parameters:

remoteDirectoryExpression - The remote directory expression.

setRemoteFileSeparator

public void setRemoteFileSeparator(String remoteFileSeparator)

Set the remote file separator; default '/'

Parameters:

remoteFileSeparator - the remote file separator.

setFilter

public void setFilter(FileListFilter<F> filter)

Set the filter to be applied to the remote files before transferring.

Parameters:

filter - the file list filter.

doSetFilter

protected final void doSetFilter(FileListFilter<F> filter)

setFileInfoJson

public void setFileInfoJson(boolean fileInfoJson)

Set to false to add the FileHeaders.REMOTE_FILE_INFO header to the raw FileInfo. Default is true meaning that common file information properties are provided in that header as JSON.

Parameters:

fileInfoJson - false to set the raw object.

Since:

5.0

getRemoteFileTemplate

protected RemoteFileTemplate<F> getRemoteFileTemplate()

afterPropertiesSet

public final void afterPropertiesSet()

Specified by:

afterPropertiesSet in interface InitializingBean

Overrides:

afterPropertiesSet in class AbstractExpressionEvaluator

doInit

protected void doInit()

Subclasses can override to perform initialization - called from InitializingBean.afterPropertiesSet().

doReceive

protected Object doReceive()

Description copied from class: AbstractMessageSource

Subclasses must implement this method. Typically the returned value will be the payload of type T, but the returned value may also be a Message instance whose payload is of type T.

Overrides:

doReceive in class AbstractFetchLimitingMessageSource<InputStream>

Returns:

The value returned.

doReceive

protected Object doReceive(int maxFetchSize)

Description copied from class: AbstractFetchLimitingMessageSource

Subclasses must implement this method. Typically the returned value will be the payload of type T, but the returned value may also be a Message instance whose payload is of type T.

Specified by:

doReceive in class AbstractFetchLimitingMessageSource<InputStream>

Parameters:

maxFetchSize - the maximum number of messages to fetch if a fetch is necessary.

Returns:

The value returned.

poll

protected AbstractFileInfo<F> poll()

remotePath

protected String remotePath(AbstractFileInfo<F> file)

rollbackFromFileToListEnd

protected void rollbackFromFileToListEnd(List<F> filteredFiles,
                                         F file)

asFileInfoList

protected abstract List<AbstractFileInfo<F>> asFileInfoList(Collection<F> files)