java - 如何在线程池中使用apache-camel DSL？

我有一个Java骆驼示例，该示例在configure方法中定义了以下路由：

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”错误。如何使这段代码与线程池一起使用，以提高其效率？

最佳答案

您只需使用以下命令即可更改代码：

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

RouteDefinition和ThreadsDefinition都扩展了ProcessorDefinition<Type>

filterdefinition

java - 如何在线程池中使用apache-camel DSL？