apache-camel - 将动态路由器 EIP 与负载均衡器 EIP 结合使用

Question

我想根据负载均衡器 EIP 发送到的位置来重定向 DynamicRouterBean 中的消息。我试图使用 @Header(Exchange.SLIP_ENDPOINT) 访问 DynamicRouterBean 中的前一个端点，但它被设置为 null（为什么？）。即使我得到 Exchange（在 DynamicRouterBean 中），fromEndPoint 也是 direct://my-lb（但预计它是 direct://my-lb-a 或 direct://my-lb-b?? ）。

后来我使用 CamelHistory 来查看消息曾经是哪些端点，但仍有问题。前一个端点（或 fromEndPoint 或 Exchange.SLIP_ENDPOINT）不是负载均衡器端点之一吗？

from("direct://my-lb")
    .loadBalance().roundRobin()
        .to("direct://my-lb-a")
        .to("direct://my-lb-b")
    .end()
.dynamicRouter(method(DynamicRouterBean.class, "slip"));

Answer 1

这对我有用，谢谢克劳斯易卜生。如果您能回答而不是发表评论，那就太好了，所以我可以接受您的回答:)

public String slip(String body, @Header(Exchange.TO_ENDPOINT) String toEndPoint) {
...
}