Configures an inbound Channel Adapter that polls a directory and sends Messages whose payloads are
instances of java.io.File.
Specify whether to automatically create the source directory if it does not yet exist when this
adapter is being initialized. The default value is 'true'. If set to 'false' and the directory
does not exist upon initialization, an Exception will be thrown.
Specify the maximum number of files stored in memory by the underlying FileReadingMessageSource.
This is useful to limit the memory footprint of this endpoint. Using a stateful filter would counter
this benefit, so AcceptOnceFileListFilter is not used when this attribute is specified.
MUTUALLY EXCLUSIVE with comparator, if comparator is set this attribute will be ignored.
MUTUALLY EXCLUSIVE with stateful filtering.
Configures an outbound Channel Adapter that writes Message payloads to a File.
The channel through which outgoing messages will arrive.
Configures an inbound channel adapter that 'tails' a file on the filesystem.
Configures the adapter to exec 'tail' with these options (appended by the file name).
Default: "-F -n 0" (follow the filename and emit no
existing lines). This attribute is not allowed if 'delay' 'end' or 'reopen' is
specified, which cause the Apache commons-io 'Tailer' class to be used instead of
using a native 'tail' command.
The fully qualified name of the file to be tailed.
A reference to a TaskExecutor; the default is a SimpleAsyncTaskExecutor; the
native adapter uses three threads - one for reading stdout, one for
reading stderr and one for monitoring the process.
A reference to a TaskScheduler; the default is the 'taskScheduler' bean
which is automatically configured for all Spring Integration applications.
The scheduler is used by the native adapter to reschedule
the 'tail' process after a failure according to the 'file-delay'.
This attribute is not allowed when using the Apache adapter.
The delay in milliseconds between attempts to open the file when no file was found (Apache adapter).
For the native adapter, this is used as a delay before starting a new process after process failures.
On some platforms, when the file doesn't exist, the 'tail' process is suspended until the file
appears; on other platforms, the 'tail' process exits immediately if the file doesn't exist.
Default 5000.
Does not apply to the native adapter - the delay in milliseconds between polls when no new
data was detected in the file. Default 1000. Note: Setting this option forces the use of the Apache
Tailer implementation instead of the native 'tail' command.
Does not apply to the native adapter.
Set to 'true' to tail from the end of the file, 'false' to tail from the beginning of the file.
Default 'true'. Note: Setting this option forces the use of the Apache
Tailer implementation instead of the native 'tail' command.
Does not apply to the native adapter.
If 'true', close and reopen the file between reading chunks.
Default 'false'. Note: Setting this option forces the use of the Apache
Tailer implementation instead of the native 'tail' command.
Message Channel to which error Messages should be sent.
Configures an outbound Gateway that writes request Message payloads to a File and then generates a
reply Message containing the newly written File as its payload.
The channel through which outgoing messages will arrive.
Specify whether this outbound gateway must return a non-null value. This value is
'true' by default, and a ReplyRequiredException will be thrown when
the underlying service returns a null value.
Allows you to provide a SpEL expression which will compute the file name of
the target file (e.g., assuming payload is java.io.File "payload.name + '.transferred'");
Extension used when uploading files. We change it after we know it's uploaded.
This attribute is mutualy exclusive with 'append' since the append is done to the
actual file and not its temporary counterpart. The default value of this attribute (i.e., .writing)
is ignored when 'append' is set to true.
Creates a Transformer that converts a File payload to a String.
Creates a Transformer that converts a File payload to an array of bytes.
Allows you to provide a SpEL expression which
will compute the directory
path where the files will be transferred to
(e.g., "headers.['remote_dir'] +
'/myTransfers'");
Allows you to provide a SpEL expression which
will compute the temporary directory
path where files will be transferred to before they are moved to the remote-directory
(e.g., "headers.['remote_dir'] +
'/temp/myTransfers'");
Specify whether to automatically create the
remote target directory if
it doesn't exist.
Allows you to specify a reference to
[org.springframework.integration.file.FileNameGenerator] bean.
Allows you to provide SpEL expression which
will compute file name of
the remote file (e.g., assuming payload
is java.io.File
"payload.getName() + '.transfered'");
Allows you to suppress using a temporary file name while writing the file.