java - Spring Integration在下一步之前完成异步转换

我有一个集成流，该流会定期轮询数据库以检索MachineLine尚未处理的所有实体并对其进行处理。该流程检索MachineLine对象的集合，然后我希望将其拆分为单个对象，将这些对象转换为ReportDetails对象，并将转换后的对象持久保存到数据库中的另一个表中。流程定义如下：

@Bean
public IntegrationFlow processMachineLine() {
    return IntegrationFlows
            .from(Jpa.inboundAdapter(this.entityManager)
                            .entityClass(MachineLine.class)
                            .jpaQuery(this.machineService.retrieveUnprocessedLinesQuery()),
                    e -> e.poller(Pollers.fixedDelay(5000)))
            .split()
            .transform(MachineLine.class, this::transformMachineLineToReportDetails)
            .handle(Jpa.outboundAdapter(this.entityManager)
                            .entityClass(ReportDetails.class),
                    ConsumerEndpointSpec::transactional)
            .get();
}

上面的定义可以正常工作，但是很慢。该transformMachineLineToReportDetails方法将HTTP请求发送到另一个服务，该服务需要花费几秒钟的时间进行响应。使用当前流定义，每个MachineLine对象在对之前的对象进行转换之前都将等待对其进行转换和持久化。

因此，理想的解决方案是异步执行此转换和持久性。一种可能的解决方案是在.split()和之间插入以下行.transform(...)：

.channel(new ExecutorChannel(Executors.newCachedThreadPool()))

但是，这允许JPA入站适配器在处理和保留上次轮询的结果之前再次轮询数据库。这意味着上MachineLine一次数据库轮询返回的，在下一次轮询之前未进行转换和保留的任何实体都将再次检索，并尝试进行第二次转换和保留。显然，这会导致不必要的资源成本，并且当多个ReportDetails具有相同ID的对象尝试保存到数据库时，也会产生错误。

有没有一种方法可以异步转换MachineLine对象，但要确保在上一次轮询的结果完成流中的访问（即所有MachineLine对象都已转换并持久化）之前，不再次轮询数据库？