支撑着骆驼的身体

Question

我试图在Apache Camel中实现以下路径：endpoint1接收消息。路由向endpoint2（清除主体）发起请求。转换器通过使用endpoint2的结果来转换endpoint1的主体，以输入消息。

我尝试了以下几点：

from("direct:MessageEndpoint1")
  .setHeader(Exchange.HTTP_METHOD, constant("GET"))
  .to("http://localhost:9003/MessageEndpoint2")
  .process(new MessageTransformationProcessor())
  .to("direct:MessageEndpoint3");

问题是，该主体被消息endpoint2覆盖。我正在考虑将消息体备份到属性中。但什么是最佳实践？

Answer 1

这里应该使用的企业集成模式是enricher。

见：http://camel.apache.org/content-enricher.html

正如您正确识别的，当您将消息发送到消息endpoint2时，消息endpoint1的正文将丢失。

相反，您应该尝试以下模式：

from("direct:MessageEndpoint1")
  .setHeader(Exchange.HTTP_METHOD, constant("GET"))
  .enrich("http://localhost:9003/MessageEndpoint2", new AggregationStrategy() {
    @Override
    public Exchange aggregate(Exchange oldExchange, Exchange newExchange) {
      // write an aggregation strategy that makes sense here...
    }
  })
  .process(new MessageTransformationProcessor())
  .to("direct:MessageEndpoint3");

通常，您可以从newExchange获取响应中所需的信息，并将其设置为oldexhage

oldExchange.setProperty("xyz", newExchange.getIn().getBody().get(...));