如何在Camel中将头字符串传递给服务

Question

from("direct:marshal-xml")
 .marshal(jaxbDataFormat)
 .to("direct:validate-and-send");

根据名为“MessageType”的头属性，我们希望使用不同的jaxbDataFormat对象来封送至XML。我们可以在路由本身中进行选择，但我们希望使用一个专用服务，该服务接受字符串输入messageType，并返回正确的JAXBDataFormat。

现在的问题是如何将标头属性“MessageType”作为参数传递给服务。我们希望使用如下内容：

from("direct:marshal-xml")
 .marshal(jaxbDataFormatService.getDataFormat(getHeader("messageType")))
 .to("direct:validate-and-send");

但是我似乎无法从标题中获得作为字符串的messageType。对路由进行“建模”的routebuilder和从该模型生成的运行时路由之间似乎存在差异。

simple("${header.messageType}").evaluate(exchange, String.class);

Answer 1

您总是可以实现自己的“复合数据格式”，例如，通过实现org.apache.camel.spi.dataformat，它将了解您想要使用的所有数据格式，并使用您想要的数据格式。

类似这样的东西，只是为了给你一个想法：

public class MyCompositeFormat implements DataFormat, CamelContextAware {

    public MyCompositeFormat(DataFormat... formats) {
        // store them to local variable
    }

    public CamelContext getCamelContext() {
        return camelContext;
    }

    public void setCamelContext(CamelContext camelContext) {
        this.camelContext = camelContext;
    }

    public void marshal(Exchange exchange, Object graph, OutputStream stream) throws Exception {
      if (exchange.getIn().getHeader("SomeHeader",String.class).equals("whatever") {
        return someFormatYouStored.marshal(exchange,graph,stream);
      } else {
        return anotherFormat.marshal(exchange,graph,stream);
      }

    }

    public Object unmarshal(Exchange exchange, InputStream stream) throws Exception {
      // similar approach to marshal
    }

}

在你的路线上：

MyCompositeFormat myCompositeFormat = new MyCompositeFormat(otherFormats);
from("direct:marshal-xml")
 .marshal(myCustomFormat)
 .to("direct:validate-and-send");