Apache Camel拆分器返回字符串

Question

<split streaming="true">
  <tokenize token="@"/>
  <to uri="validateResubmitTransactionIdProcessor"/>
</split>

epublic class ValidateResubmitTransactionIdProcessor implements Processor {
public void process(Exchange exchng) throws Exception {
    Object[] args =  exchng.getIn().getBody(Object[].class);
}}

eCaused by：org.apache.camel.InvalidPayloadException：没有类型为：org.apache.camel.Exchange的可用正文，但其值为：11484类型为：java.lang.String on：message：11484。原因：没有类型转换器可用于将类型：java.lang.String转换为所需的类型:org.apache.camel.exchange（值为11484）。交换[消息:11484]。由:[org.apache.camel.notypeConversionAvailableException-没有类型转换器可用于将类型:java.lang.String转换为所需类型:org.apache.camel.impl.messagesupport.getMandatoryBody（messagesupport.java:101)和值为11484的required类型:org.apache.camel.builder.expressionBuilder$35..camel.impl.converter.basetypeConverterRegistry.mandatoryConvertto（basetypeConverterRegistry.java:169)在org.apache.camel.core.osgi.osgitypeConverter.mandatoryConvertto（osgitypeConverter.java:110)在org.apache.camel.impl.messagesupport.getMandatoryBody（messagesupport.java:99)nter

我不确定我是否使用了正确的方式拆分器。另外，请知道如何将java.lang.String转换为Exchange。这似乎没有得到骆驼的支持。

Answer 1

拆分器EIP创建了一种循环，每个令牌都会调用处理器。因此，交换的主体包含一个简单的字符串，而不是列表。

更新：请参见此示例：

    CamelContext context = new DefaultCamelContext();
    context.addRoutes(new RouteBuilder() {
        public void configure() {
            from("direct:start")
            .split().tokenize("@").streaming()
            .process(new MyProcessor())
            ;
        }
    });
    context.start();
    context.createProducerTemplate().sendBody("direct:start", "1@2@3");

您的处理器方法可以如下所示：

public void process(final Exchange exchange) throws Exception
{
    System.out.println(exchange.getIn().getBody());
}