F - the target file type.S - the target RemoteFileStreamingInboundChannelAdapterSpec implementation type.MS - the target AbstractInboundFileSynchronizingMessageSource implementation type.public abstract class RemoteFileStreamingInboundChannelAdapterSpec<F,S extends RemoteFileStreamingInboundChannelAdapterSpec<F,S,MS>,MS extends AbstractRemoteFileStreamingMessageSource<F>>
extends org.springframework.integration.dsl.MessageSourceSpec<S,MS>
implements org.springframework.integration.dsl.ComponentsRegistration
MessageSourceSpec for an AbstractInboundFileSynchronizingMessageSource.| Constructor and Description |
|---|
RemoteFileStreamingInboundChannelAdapterSpec() |
| Modifier and Type | Method and Description |
|---|---|
S |
filter(FileListFilter<F> filter)
Configure a
FileListFilter to be applied to the remote files before
copying them. |
S |
filterExpression(java.lang.String expression)
Configure the
ExpressionFileListFilter. |
S |
filterFunction(java.util.function.Function<F,java.lang.Boolean> filterFunction)
Configure the
ExpressionFileListFilter. |
java.util.Map<java.lang.Object,java.lang.String> |
getComponentsToRegister() |
S |
maxFetchSize(int maxFetchSize)
Specify the maximum number of remote files that will be fetched on each fetch
attempt.
|
abstract S |
patternFilter(java.lang.String pattern)
Configure a simple pattern filter (e.g.
|
abstract S |
regexFilter(java.lang.String regex)
Configure a regex pattern filter (e.g.
|
S |
remoteDirectory(org.springframework.expression.Expression remoteDirectoryExpression)
Specify an expression that evaluates to the full path to the remote directory.
|
S |
remoteDirectory(java.util.function.Function<org.springframework.messaging.Message<?>,java.lang.String> remoteDirectoryFunction)
Specify a function that is invoked to determine the full path to the remote directory.
|
S |
remoteDirectory(java.lang.String remoteDirectory)
Specify the full path to the remote directory.
|
S |
remoteFileSeparator(java.lang.String remoteFileSeparator)
Configure the file name path separator used by the remote system.
|
public RemoteFileStreamingInboundChannelAdapterSpec()
public S remoteFileSeparator(java.lang.String remoteFileSeparator)
remoteFileSeparator - the remoteFileSeparator.public S remoteDirectory(java.lang.String remoteDirectory)
remoteDirectory - the remoteDirectory.AbstractRemoteFileStreamingMessageSource.setRemoteDirectory(String)public S remoteDirectory(org.springframework.expression.Expression remoteDirectoryExpression)
remoteDirectoryExpression - The remote directory expression.public S remoteDirectory(java.util.function.Function<org.springframework.messaging.Message<?>,java.lang.String> remoteDirectoryFunction)
remoteDirectoryFunction - The remote directory function.public S filter(FileListFilter<F> filter)
FileListFilter to be applied to the remote files before
copying them.filter - the filter.public S filterExpression(java.lang.String expression)
ExpressionFileListFilter.expression - the SpEL expression for files filtering.FileReadingMessageSource.setFilter(FileListFilter),
ExpressionFileListFilterpublic S filterFunction(java.util.function.Function<F,java.lang.Boolean> filterFunction)
ExpressionFileListFilter.filterFunction - the Function for files filtering.FileReadingMessageSource.setFilter(FileListFilter),
ExpressionFileListFilterpublic S maxFetchSize(int maxFetchSize)
maxFetchSize - the max fetch size.MessageSourceManagement.setMaxFetchSize(int)public java.util.Map<java.lang.Object,java.lang.String> getComponentsToRegister()
getComponentsToRegister in interface org.springframework.integration.dsl.ComponentsRegistrationpublic abstract S patternFilter(java.lang.String pattern)
pattern - the pattern.filter(FileListFilter)public abstract S regexFilter(java.lang.String regex)
regex - the regex.filter(FileListFilter)