Spring Integration - scatter-gather - releaseExpression中的动态值

Question

我在 Spring Integration 流程中使用 scatter-gatter 来并行调用 3 个服务：

                    .scatterGather(rlr -> rlr.applySequence(true)
                                             .recipientFlow(f1 -> f1
                                                    .channel(c -> c.executor(executorMLCalls))
                                                    .route(ifService1NeedsToBeCalled(), routeToService1OrBypassCall()))
                                             .recipientFlow(f2 -> f2
                                                    .channel(c -> c.executor(executorMLCalls))
                                                    .enrich(this::service2RequestEnricher)
                                                    .enrich(this::service2Enricher))
                                             .recipientFlow(f3 -> f3
                                                    .channel(c -> c.executor(executorMLCalls))
                                                    .enrich(this::service3RequestEnricher)
                                                    .enrich(this::service3Enricher)),
                                   agg -> agg.correlationStrategy(msg -> msg.getHeaders().get("corrMLCalls"))
                                             .releaseExpression("size() == 3"),
                                   sgs -> sgs.gatherTimeout(gatherTimeout)
                                             .requiresReply(true)
                    )

所以 service2 和 service3 必须始终被调用，但调用 service1 取决于条件。
因此，我不能使用 size() == 3 释放表达式，因为有时它应该是 size() == 2。

如何在表达式中使用动态值？可以在release表达式中调用本地方法吗？

谢谢！

问候，
五、

Answer 1

是的，这样的表达式是 BeanFactory-aware，您可以使用 @ 语法来访问应用程序上下文中的任何 bean。

另一方面，有一个：

/**
 * @param releaseStrategy the release strategy.
 * @return the handler spec.
 * @see AbstractCorrelatingMessageHandler#setReleaseStrategy(ReleaseStrategy)
 */
public S releaseStrategy(ReleaseStrategy releaseStrategy) {

这可能会根据您的环境和MessageGroup 作为发布候选者做出任何决定。