如何在线程池中使用apache-camel DSL？
如何在线程池中使用apache-camel DSL？
提问于 2014-02-26 20:59:21
我有一个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”错误。如何让这段代码与线程池一起工作以提高其效率？
回答 1
Stack Overflow用户
回答已采纳
发布于 2014-02-26 21:27:36
您可以简单地用以下方法更改代码：
ThreadsDefinition route = from("...").threads(10);RouteDefinition和ThreadsDefinition都扩展了ProcessorDefinition<Type>
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/22053125
复制相关文章
相似问题
腾讯云开发者
