-
Notifications
You must be signed in to change notification settings - Fork 4
Open
Description
Lines 93 to 98 in 88f7435
public MessageSource<InputStream> sftpMessageSource() { | |
SftpStreamingMessageSource messageSource = new SftpStreamingMessageSource(template()); | |
messageSource.setRemoteDirectory(properties.getRemoteDirectory()); | |
if(properties.getFilterPattern() != null && !"".equals(properties.getFilterPattern())) | |
messageSource.setFilter(new SftpRegexPatternFileListFilter(properties.getFilterPattern())); | |
return messageSource; |
The sftp inbound chanel should only process files once.
configuring the sftp-streaming adapter with a metadatastore should allow to process file only once (using redis
) for this repo.
Metadata
Metadata
Assignees
Labels
No labels