搜索

第 364 章 虚拟机组件

download PDF

可作为 Camel 版本 1.1 提供

vm: 组件提供异步 SEDA 行为,在 BlockingQueue 上交换消息,并在单独的线程池中调用消费者。

此组件与 Seda 组件不同,因为虚拟机支持 CamelContext 实例间的通信 - 因此,您可以使用此机制在 web 应用程序间通信(提供 camel-core.jar 是在 系统/引导 类路径上)。

虚拟机是 Seda 组件的扩展。

364.1. URI 格式

vm:queueName[?options]

其中 queueName 可以是任何字符串,以在 JVM 中唯一标识端点(或者至少在加载 camel-core.jar 的类加载器中)

您可以使用以下格式将查询选项附加到 URI: ?option=value&option=value&…​

必须与制作者和消费者端点 URI 使用完全相同的 虚拟机 端点 URI。否则,Camel 会创建第二个 虚拟机 端点,尽管 URI 的 queueName 部分是相同的。例如:

from("direct:foo").to("vm:bar?concurrentConsumers=5");

from("vm:bar?concurrentConsumers=5").to("file://output");

请注意,我们必须使用完整的 URI,包括生产者和消费者中的选项。

在 Camel 2.4 中这个问题已被解决,因此只有队列名称必须匹配。使用队列名称 bar,您可以按照如下所示重写前面的 exmple:

from("direct:foo").to("vm:bar");

from("vm:bar?concurrentConsumers=5").to("file://output");
Red Hat logoGithubRedditYoutubeTwitter

学习

尝试、购买和销售

社区

关于红帽文档

通过我们的产品和服务,以及可以信赖的内容,帮助红帽用户创新并实现他们的目标。

让开源更具包容性

红帽致力于替换我们的代码、文档和 Web 属性中存在问题的语言。欲了解更多详情,请参阅红帽博客.

關於紅帽

我们提供强化的解决方案,使企业能够更轻松地跨平台和环境(从核心数据中心到网络边缘)工作。

© 2024 Red Hat, Inc.