У меня настроено следующее InboundChannelAdapter
:
@Bean
@InboundChannelAdapter(channel = "inbound", poller = [Poller(cron = "0/5 * * * * *")])
fun sftpHualingMessageSource(): MessageSource<File> {
val metadataStore = PropertiesPersistingMetadataStore()
metadataStore.setBaseDirectory(metadataStoreDirectory)
val source = SftpInboundFileSynchronizingMessageSource(sftpInboundHualingFileSynchronizer())
source.setLocalDirectory(File(sftpLocalDirectoryHualingDownload))
source.setAutoCreateLocalDirectory(true)
source.setLocalFilter(FileSystemPersistentAcceptOnceFileListFilter(metadataStore, "devices"))
return source
}
Однако файл metadata-store.properties
не создается.
Я также вижу странное поведение, которое, по моему мнению, связано,Когда сервер весенней загрузки перезапускается, он снова обрабатывает локальные копии файлов (csv).Затем он попытается переместить файл на удаленный сервер (что уже сделано), но если это не удастся, он удалит его из папки, в которой он также был перемещен.