Запуск потока интеграции Spring одновременно для каждого файла Ftp

У меня есть поток интеграции, настроенный с использованием Java DSL, который извлекает файл с Ftp-сервера с помощью Ftp.inboundChannelAdapter, затем преобразует его в JobRequest, затем у меня есть метод .handle(), который запускает мое пакетное задание, все работает в соответствии с требованиями, но процесс выполняется последовательно для каждого файла внутри FTP-папки

Я добавил currentThreadName в свою конечную точку Transformer, он печатал одно и то же имя потока для каждого файла.

Вот что я пробовал до сих пор

1.компонент-исполнитель задач

 @Bean
    public TaskExecutor taskExecutor(){
        return new SimpleAsyncTaskExecutor("Integration");

    }

2. поток интеграции

  @Bean
public IntegrationFlow integrationFlow(JobLaunchingGateway jobLaunchingGateway) throws IOException {
    return IntegrationFlows.from(Ftp.inboundAdapter(myFtpSessionFactory)
                    .remoteDirectory("/bar")
                    .localDirectory(localDir.getFile())
            ,c -> c.poller(Pollers.fixedRate(1000).taskExecutor(taskExecutor()).maxMessagesPerPoll(20)))
            .transform(fileMessageToJobRequest(importUserJob(step1())))
            .handle(jobLaunchingGateway)
            .log(LoggingHandler.Level.WARN, "headers.id + ': ' + payload")
            .route(JobExecution.class,j->j.getStatus().isUnsuccessful()?"jobFailedChannel":"jobSuccessfulChannel")
            .get();
}

3. Я также прочитал в другом потоке SO, что мне нужно ExecutorChannel, поэтому я настроил его, но я не знаю, как внедрить этот канал в мой Ftp.inboundAdapter, из журналов видно, что канал всегда integrationFlow.channel#0, который, я думаю, является DirectChannel

 @Bean
public MessageChannel inputChannel() {
    return new ExecutorChannel(taskExecutor());
}

Я не знаю, чего мне здесь не хватает, или, возможно, я неправильно понял систему обмена сообщениями Spring, поскольку я очень новичок в Spring и Spring-Integration.

Любая помощь приветствуется

Спасибо