java - 如何将 apache-camel DSL 与线程池一起使用？

Question

我有一个 Java Camel 示例，它在配置方法中定义了以下路由:

public final void configure() throws OperationNotSupportedException{
    RouteDefinition route = from("xmpp://localhost:5222/?blablabla...");

    // apply pre-processing filter
    FilterDefinition filterDefinition = route.filter().method(...);

    // apply main processor
    ExpressionNode expressionNode = filterDefinition.process(...);

    //apply post-processing filter
    filterDefinition = expressionNode.filter().method(...);

    // set destination
    expressionNode = filterDefinition.to("esper://session_X");
}

不过这段代码也是一个瓶颈，我想提高它的效率。为了实现这一点，我尝试使用线程池:

RouteDefinition route = from("xmpp://localhost:5222/?blablabla...").threads(10);

但是我总是收到错误。在这种情况下，我收到“无法从 RouteDefinition 转换为 ThreadsDefinition”错误。我怎样才能让这段代码与线程池一起工作以提高其效率？

Answer 1

您只需更改代码即可:

ThreadsDefinition route = from("...").threads(10);

RouteDefinition和ThreadsDefinition两者都延伸ProcessorDefinition<Type>