Camel Spliter使用自定义拆分方法

Question

我可能在这里做错了但是在使用split().方法组合时我似乎没有得到预期的结果.传入的xml在传入的消息之间略有不同,其中的elementKey节点描述了我们正在寻找的XML节点.

from("direct:fromWhereEver")
  ...
  .setHeader("dynamicToken", xpath("//*[local-name()='elementKey']/text()").stringResult())
  ...
  .split().method(DynamicSplitToken.class, "extractTokens")
    .to("direct:outgoing")
.routeId("BhahBlah")

我在路由使用的方法中定义了以下内容

public class DynamicSplitToken {
    public static Expression extractTokens(Exchange exchange){

        String splitToken = exchange.getIn().getHeader("dynamicToken").toString();

        TokenizeLanguage tok = new TokenizeLanguage();
        tok.setXml(true);
        tok.setIncludeTokens(true);
        tok.setToken(splitToken);

        return tok.createExpression();
    }
}

现在从消息中提取xml标签没有问题,但是提取和推送的结果"主体"包含 <tagname>...</tagname>与上面的elementKey匹配,其间没有子节点/元素.我希望在标签之间也能收到所有内容,类似于我使用以下内容

.split().tokenizeXML("tagname")

使用这种方法时,我得到了标签和标签之间所有节点的完整内容,不幸的是我无法将{header.dynaimcToken}传递给tokenizeXML ProcessorDefinition,否则我不需要在这里寻求帮助.

我在哪里出错了,我知道我错过了方法处理器之后的一个重要步骤,但不确定是什么

现在,如果有所作为,我们会遇到骆驼2.9(fuse-esb)

干杯马克

Answer 1

method()不得返回 an Expresssionbut 可迭代的东西，例如java.util.List，请参见此处。您的原始解决方案非常接近，但您必须evaluate使用表达式并返回其结果，例如：

protected static class DynamicSplitToken {
    @SuppressWarnings("unchecked")
    public static List<String> extractTokens(final Exchange exchange) {
        final String splitToken = exchange.getIn().getHeader("dynamicToken").toString();

        final TokenizeLanguage tok = new TokenizeLanguage();
        tok.setXml(true);
        tok.setIncludeTokens(true);
        tok.setToken(splitToken);

        final Expression expression = tok.createExpression();
        return expression.evaluate(exchange, List.class);
    }
}