Spring Integration Mono<?> 或 CompletableFuture<?> 与 async false

Question

我们如何在

Spring Integration 5.x

中使用

ListenableFuture

或

Mono<?>

实现相当于 CompletableFuture async=false 的效果？

我们有很多来自公共库的反应式处理程序（服务激活器模式），并且不希望将它们重写为正常的阻塞

GenericHandler

。

请推荐。

P.S: 根据文档 ListenableFuture 在 Spring Integration 6.x 中已弃用，因此希望实现未来（Spring Integration 6.x）的方式。谢谢

Answer 1

如果您这样做

async=false

，则

Mono

或

CompletableFuture

将作为来自处理程序的回复消息的有效负载。从这里开始，您就可以在集成流程的下一步中自行处理该有效负载。

也许，如果您分享一些场景示例，我们可以帮助确定您的配置或逻辑中必须执行哪些操作以及如何执行。