程序员经验分享-hwhale

如何设置camel处理器或其他路由成分的id

2024-03-01

Camel 自动生成处理器和其他内容的 ID（processor1..processor25）。有没有办法设置这个名字？我们需要通过 jmx 识别某些处理器来获取遥测数据。

我想要设置的名称是通过属性给出的 - 它们在开始时是已知的。因此，我需要在定义路由时或在处理器内设置它们（名称通过处理器构造函数给出，字符串也用于处理）。

Update

示例：对于路线from("some:where").process(myProcessor).to(no:where)我需要设置 myProcessor 的 id。我需要来自某些处理器的“ExchangesTotal”和其他内容

我需要 Java DSL 的解决方案。


如果使用 xml，则使用 id 属性。

<to id="foo" uri="seda:foo"/>

如果使用java代码，那么使用.id

.to("seda:bar").id("foo");

其中一个特殊之处是设置路由的 id，您必须使用它.routeId

from("xxx").routeId("id of the route")
   .to("xxx")

所以你的例子应该是

from("some:where").process(myProcessor).id("theIdOfTheProcessorYouWant").to(no:where)
本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系:hwhale#tublm.com(使用前将#替换为@)

apachecamel

如何设置camel处理器或其他路由成分的id 的相关文章

  • 异常未传播到 Apache Camel 中的错误处理程序

    我有一条定义 doTry doCatch 块的路线 当在 doCatch 块中处理异常时 我希望将其传播到错误处理程序 以确保消息在本地处理后添加到死信队列中 问题是我无法让错误处理程序的传播正常工作 defaultErrorHandler

  • 是否可以在自定义组件中使用骆驼组件？

    我最近开始使用 Apache Camel 我们正在考虑创建自定义组件来抽象大量逻辑并简化路由 但其中一些逻辑涉及 http 请求和其他部分 这些部分具有我们想要利用的现有 Camel 组件 是否可以从我们的自定义组件的生产者中调用其他组件

  • Camel - 流缓存不缓存/无法转换？

    读完一遍之后 我似乎失去了 内在 的身体 请注意 我使用的是 Camel 的流缓存 并且输入是来自 http 组件的 json 文件 我有一个带有以下代码的处理器 log debug Body Type exchange getIn get

  • 批量消费骆驼kafka

    尽管遵循此处发布的示例 但我无法与卡夫卡骆驼消费者一起批量阅读 我是否需要对生产者进行更改 或者问题最有可能出在我的消费者配置上 有问题的应用程序利用卡夫卡骆驼组件 https camel apache org components 3 1

  • Apache Camel HTTP 显示请求和响应

    我正在使用 Apache Camel 将数据从 CSV 文件加载到 Web 服务 无论如何我可以显示请求和响应 下面是路由配置 我从数组中拆分并聚合 100 个项目 以作为 POST 正文发送 from fileLocation unmar

  • 如何在骆驼单元测试中模拟多个组件？

    我正在使用CamelTestSupport在骆驼版本 2 13 1 中 我想做这样的事情来模拟两个不同的组件 Override public String isMockEndpoints return activemq exec 我不能只是

  • 使用 MockEndPointsandSkip 进行 Camel 单元测试

    我是 Camel 新手 正在尝试一些代码来了解 MockEndpoints 功能的工作原理 但它不起作用 以下是我想使用 MockEndpoints 进行单元测试的 Camel 路线 属性值在 application properties

  • Camel - 将特定参数从路由传递到通用 bean 方法

    假设我有一条骆驼路线 如下所示 from direct myRoute setHeader someHeader simple some header value beanRef myBean beanMethod 我有一颗豆子cannot

  • Camel是否为每条路线创建一个线程

    最近我开始使用camel 我发现它有可能满足我的许多集成层需求 我创建了一个 java 客户端应用程序 不在任何容器中运行 其中定义了两条路由 路线 1 将文件从传入文件夹 1 移动到文件夹 2 路线2 将文件内容从folderx移动到mq

  • apache.camel 中 Exchange 的 getIn() 与 getMessage()

    我尝试理解 apache camel Exchange 的 getIn 和 getMessage 之间的区别 在文档中 它说 getIn 返回入站消息 而 getMessage 返回当前消息 我的问题是 当当前处理器中未更改入站消息时 ge

  • Apache Camel：带有 CxfEndpoint 的 RouteBuilder

    Hello 我正在尝试使用 Java DSL 和 RouteBuilder 实现 Camel 路线 我想从计时器端点发送到 cxf 端点 Code public class MyRoute extends RouteBuilder Over

  • 如何为周一至周五的每日会话配置 QuickFix/J？

    我在用快速修复 J http quickfixengine org 1 6 4 英寸骆驼快速修复 https camel apache org staging components latest quickfix component htm

  • 如何让 Spring 连接我的 JmsComponent

    我正在编写一个使用 Akka Akka Camel 和 Spring 进行配置的应用程序 应用程序需要充当针对各种应用程序服务器的独立 JMS 客户端 为此 它需要使用 JNDI 设置 JMS 连接工厂 我正在用 jBoss 测试这个 我对

  • Apache Camel 根据请求使用文件内容丰富消息

    我正在实现 RESTful 服务 使用 CXFRS 组件 它应该返回某些请求的文件 每个文件都通过其 id 和扩展名来获取 即restfulservice com path file 1 pdf 每个文件一旦添加就不会改变 文件在获取后不应

  • 如何在camel Rest中验证JSON请求

    我需要根据某种模式验证对骆驼休息服务的传入请求 例如 根据要求 如下所示 routeId fileBatchRoute action start sourceLocation sourceDirectory destinationLocat

  • Apache Camel：如何存储变量以供以后使用

    在使用 Spring DSL 玩 Camel 时 我遇到了以下问题 假设预期的消息流如下所示 客户端将带有 XML 正文的 HTTP POST 消息发送给 CAMEL CAMEL 向服务器代理 HTTP POST 消息 并使用稍微调整的 U

  • 骆驼：我如何异步发送到端点

    如何在不等待端点的路由被处理的情况下向端点发送消息 也就是说 我的路由应该只分派消息并完成 wireTap endpoint 就是答案

  • Apache Camel POJO Bean 处理器单例还是原型？

    我使用 Camel 的 spring DSL 来构建路由 并使用 POJO bean 作为处理器 最初 我这样做

  • 在apachecamel中处理大型压缩文件

    我正在尝试获取一个文件 zip从 ftp 服务器压缩并尝试将其存储在 S3 中 gzip使用骆驼压缩 以下是我目前的路线 from sftp username host file path password

  • WebSphere Camel JMS、spring、taskExecutor、haninging 线程

    我正在尝试将 Camel 与 WebSphere 集成 除了一件事之外 它工作得很好 场景如下 JMS WMQ gt 路由 转换 gt BEAN 执行 JPA OpenJPA1 2 DB2 提交 为了能够插入WAS事务管理器和mangaed

随机推荐

热门标签