如何从 headers 动态解析处理程序和方法？

Question

我的流程是这样的

private IntegrationFlow myChannel() {
    return f -> f
            ...
            .handle("myHandler", "myMethod")
            ...
}

如何从 headers 中动态解析处理程序 myHandler 和方法 myMethod？

Answer 1

为每个 header 值添加一个带有子流程的 .router()。

Answer 2

我们首先要了解这样一个业务逻辑的目的是什么

我想我们可以用这段代码实现您的要求：

.handle((p, h) -> 
        new MethodInvokingMessageProcessor(h.get("myHandler"), h.get("myMethod", String.class)
                        .processMessage(new GenericMessage<>(p, h))))

如何从 headers 动态解析处理程序和方法？

How to resolve the handler and the method dynamically from the headers?

spring-integration

spring-integration-dsl