Я не могу запустить обработчики активатора службы последовательно, похоже, они не запускаются один за другим. В приведенном ниже коде метод fileWriterMessageHandler вызывается перед методом fileUpload. Каково стандартное возвращаемое значение, которое должен вернуть fileUpload?
@Bean
public IntegrationFlow
inboundChannelFlow(@Value("${file.poller.delay}") long delay,
@Value("${file.poller.messages}") int maxMsgsPerPoll,
TaskExecutor taskExecutor, MessageSource<File> fileSource)
{
return IntegrationFlows.from(fileSource,
c -> c.poller(Pollers.fixedDelay(delay)
.taskExecutor(taskExecutor)
.maxMessagesPerPoll(maxMsgsPerPoll)))
.handle("AWSFileManager", "fileUpload")
.handle(fileWriterMessageHandler())
.channel(ApplicationConfiguration.inboundChannel)
.get();
}