org.springframework.integration.dsl.file

Class RemoteFileInboundChannelAdapterSpec<F,S extends RemoteFileInboundChannelAdapterSpec<F,S,MS>,MS extends org.springframework.integration.file.remote.synchronizer.AbstractInboundFileSynchronizingMessageSource<F>>

java.lang.Object

org.springframework.integration.dsl.core.IntegrationComponentSpec<S,H>

org.springframework.integration.dsl.core.MessageSourceSpec<S,MS>

org.springframework.integration.dsl.file.RemoteFileInboundChannelAdapterSpec<F,S,MS>

Type Parameters:

F - the target file type.

S - the target RemoteFileInboundChannelAdapterSpec implementation type.

MS - the target AbstractInboundFileSynchronizingMessageSource implementation type.

All Implemented Interfaces:

org.springframework.beans.factory.FactoryBean<MS>, ComponentsRegistration

Direct Known Subclasses:

FtpInboundChannelAdapterSpec, SftpInboundChannelAdapterSpec

public abstract class RemoteFileInboundChannelAdapterSpec<F,S extends RemoteFileInboundChannelAdapterSpec<F,S,MS>,MS extends org.springframework.integration.file.remote.synchronizer.AbstractInboundFileSynchronizingMessageSource<F>>
extends MessageSourceSpec<S,MS>
implements ComponentsRegistration

A MessageSourceSpec for an AbstractInboundFileSynchronizingMessageSource.

Author:

Artem Bilan

Field Summary

Fields

Modifier and Type	Field and Description
protected org.springframework.integration.file.remote.synchronizer.AbstractInboundFileSynchronizer<F>	synchronizer

Fields inherited from class org.springframework.integration.dsl.core.IntegrationComponentSpec

logger, PARSER, target

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	RemoteFileInboundChannelAdapterSpec(org.springframework.integration.file.remote.synchronizer.AbstractInboundFileSynchronizer<F> synchronizer)

Method Summary

Modifier and Type	Method and Description
S	autoCreateLocalDirectory(boolean autoCreateLocalDirectory) Configure whether the local directory should be created by the adapter.
S	deleteRemoteFiles(boolean deleteRemoteFiles)
S	filter(org.springframework.integration.file.filters.FileListFilter<F> filter) Configure a FileListFilter to be applied to the remote files before copying them.
java.util.Collection<java.lang.Object>	getComponentsToRegister()
S	localDirectory(java.io.File localDirectory) Configure the local directory to copy files to.
S	localFilename(Function<java.lang.String,java.lang.String> localFilenameFunction) Configure a Function to be invoked to generate the local file name; argument passed to the apply method is the remote file name.
S	localFilenameExpression(org.springframework.expression.Expression localFilenameExpression) Configure a SpEL expression to generate the local file name; the root object for the evaluation is the remote file name.
S	localFilenameExpression(java.lang.String localFilenameExpression) Configure a SpEL expression to generate the local file name; the root object for the evaluation is the remote file name.
S	localFilter(org.springframework.integration.file.filters.FileListFilter<java.io.File> localFileListFilter)
abstract S	patternFilter(java.lang.String pattern) Configure a simple pattern filter (e.g.
S	preserveTimestamp(boolean preserveTimestamp)
abstract S	regexFilter(java.lang.String regex) Configure a regex pattern filter (e.g.
S	remoteDirectory(java.lang.String remoteDirectory)
S	remoteDirectoryExpression(org.springframework.expression.Expression remoteDirectoryExpression) Specify an expression that evaluates to the full path to the remote directory.
S	remoteFileSeparator(java.lang.String remoteFileSeparator) Configure the file name path separator used by the remote system.
S	temporaryFileSuffix(java.lang.String temporaryFileSuffix) Configure a suffix to temporarily apply to the local filename; when copied the file is renamed to its final name.

Methods inherited from class org.springframework.integration.dsl.core.IntegrationComponentSpec

_this, doGet, get, getId, getObject, getObjectType, id, isSingleton

Methods inherited from class java.lang.Object

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

Field Detail

synchronizer

protected final org.springframework.integration.file.remote.synchronizer.AbstractInboundFileSynchronizer<F> synchronizer

Constructor Detail

RemoteFileInboundChannelAdapterSpec

protected RemoteFileInboundChannelAdapterSpec(org.springframework.integration.file.remote.synchronizer.AbstractInboundFileSynchronizer<F> synchronizer)

Method Detail

autoCreateLocalDirectory

public S autoCreateLocalDirectory(boolean autoCreateLocalDirectory)

Configure whether the local directory should be created by the adapter.

Parameters:

autoCreateLocalDirectory - the autoCreateLocalDirectory

Returns:

the spec.

localDirectory

public S localDirectory(java.io.File localDirectory)

Configure the local directory to copy files to.

Parameters:

localDirectory - the localDirectory.

Returns:

the spec.

localFilter

public S localFilter(org.springframework.integration.file.filters.FileListFilter<java.io.File> localFileListFilter)

Parameters:

localFileListFilter - the localFileListFilter.

Returns:

the spec.

See Also:

AbstractInboundFileSynchronizingMessageSource.setLocalFilter(FileListFilter)

remoteFileSeparator

public S remoteFileSeparator(java.lang.String remoteFileSeparator)

Configure the file name path separator used by the remote system. Defaults to '/'.

Parameters:

remoteFileSeparator - the remoteFileSeparator.

Returns:

the spec.

localFilenameExpression

public S localFilenameExpression(java.lang.String localFilenameExpression)

Configure a SpEL expression to generate the local file name; the root object for the evaluation is the remote file name.

Parameters:

localFilenameExpression - the localFilenameExpression.

Returns:

the spec.

localFilename

public S localFilename(Function<java.lang.String,java.lang.String> localFilenameFunction)

Configure a Function to be invoked to generate the local file name; argument passed to the apply method is the remote file name.

Parameters:

localFilenameFunction - the localFilenameFunction.

Returns:

the spec.

See Also:

FunctionExpression

localFilenameExpression

public S localFilenameExpression(org.springframework.expression.Expression localFilenameExpression)

Configure a SpEL expression to generate the local file name; the root object for the evaluation is the remote file name.

Parameters:

localFilenameExpression - the localFilenameExpression.

Returns:

the spec.

Since:

1.1.1

temporaryFileSuffix

public S temporaryFileSuffix(java.lang.String temporaryFileSuffix)

Configure a suffix to temporarily apply to the local filename; when copied the file is renamed to its final name. Default: '.writing'.

Parameters:

temporaryFileSuffix - the temporaryFileSuffix.

Returns:

the spec.

remoteDirectory

public S remoteDirectory(java.lang.String remoteDirectory)

Parameters:

remoteDirectory - the remoteDirectory.

Returns:

the spec.

See Also:

AbstractInboundFileSynchronizer.setRemoteDirectory(String)

remoteDirectoryExpression

public S remoteDirectoryExpression(org.springframework.expression.Expression remoteDirectoryExpression)

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

Parameters:

remoteDirectoryExpression - The remote directory expression.

Returns:

the spec.

Since:

1.1.1

filter

public S filter(org.springframework.integration.file.filters.FileListFilter<F> filter)

Configure a FileListFilter to be applied to the remote files before copying them.

Parameters:

filter - the filter.

Returns:

the spec.

patternFilter

public abstract S patternFilter(java.lang.String pattern)

Configure a simple pattern filter (e.g. '*.txt').

Parameters:

pattern - the pattern.

Returns:

the spec.

See Also:

filter(FileListFilter)

regexFilter

public abstract S regexFilter(java.lang.String regex)

Configure a regex pattern filter (e.g. '[0-9].*.txt').

Parameters:

regex - the regex.

Returns:

the spec.

See Also:

filter(FileListFilter)

deleteRemoteFiles

public S deleteRemoteFiles(boolean deleteRemoteFiles)

preserveTimestamp

public S preserveTimestamp(boolean preserveTimestamp)

getComponentsToRegister

public java.util.Collection<java.lang.Object> getComponentsToRegister()

Specified by:

getComponentsToRegister in interface ComponentsRegistration