apache-camel 相关问题

org.apache.camel.FailedToCreateRouteException：创建路由失败：因为名称为静态方法：methodA() 在类中找不到：

我正在使用 mockito 和 camelTestSupport 编写骆驼路线测试，但测试失败并出现以下错误： 由以下原因引起：org.apache.camel.component.bean.MethodNotFoundException：带有 na 的静态方法...

错误：在设置 bean 属性“clientConnectionManager”时无法解析对 bean“myHttpConnectionManager”的引用

我正在进行从 2.25.4 到 3.0.24 的骆驼迁移。这样做时，我必须在 camel 配置 xml 文件中做一些更改，其中 httpConnectionManager 已更新为 bean 的 clientConnectionManager

JMS 生产者使用 apache camel 将消息发送到特定的队列管理器

我有一个应用程序，它使用来自队列 queuename1 的消息并且标题 JMSReplyTo = queue://MQA1/queuename2。然后它处理该消息并将响应发送到 JMSReplyTo 中提供的队列。 ...

骆驼路线，每个“步骤”都是事件驱动的

这是我的骆驼路线。 这是我的骆驼路线。 <route> <from uri="direct:foo"/> <to uri="bean:com.foo.processors.Foo?method=process(*, 'validate')"/> <to uri="bean:com.foo.processors.Foo?method=process(*, 'save')"/> <to uri="bean:com.foo.processors.Foo?method=process(*, 'transform')"/> <to uri="bean:com.foo.processors.Foo?method=process(*, 'save')"/> <to uri="bean:com.foo.processors.Foo?method=process(*, 'transport')"/> </route> 我希望能够： 让每个方法都对来自 Kafka 的事件做出反应（第一个除外）。一旦它收到一个事件，它就会发布一个事件到下一步。 下一步（“to”）只有在从 Kafka 获得适当的事件时才会触发。 我确定我编写这条路线的方式对于这个用例来说过于复杂（而且不适合）。我什至不确定 Camel 是否是“暂停”模式下此编排的正确选择。 有什么建议吗？基本上，我希望每一步都对事件做出反应，并为下一步发布更多事件。

使用 maven 运行我的项目时出现 camel-maven 错误

使用此命令运行我的项目时出现以下错误：mvn -e camel:run [错误] 未能执行目标 org.apache.camel:camel-maven-plugin:2.10.4:run (default-cli) on 项目

使用 Apache Camel 读取和拆分大文件

我正在尝试使用 Camel 读取一个大约 1 GB 的非常扁平的文件。记录由一组字符串分隔，我正在尝试以下路线。 来自（传入文件路径+“？删除=真”） ...

固定长度类型的骆驼绑定，我们可以有带有集合列表的主体吗？我面临问题

我有2个地址。 1- XYZ 2- PQR。 在这里，我需要 { 姓名：XYZ， 地址：[ XYZ, PQR ] } 解组时我无法创建地址列表 from("file:test").setBody().groovy("请求...

带骆驼弹簧启动器的弹簧启动器 - 路由加载两次

我正在尝试将弹簧靴与骆驼一起使用。在使用 camel routebuilder 定义路由时，似乎正在为一个路由定义创建两条路由。以下是项目设置的详细信息 - ...

How to pass custom headers in apache Camel Salesforce Component Making REST calls

我正在尝试在请求中传递一些自定义标头，并尝试像这样编组对我的 DTO 的响应，但它通过说接收标头而出错。此外，我没有找到任何文档......

只有当表达式在 apache 骆驼选择中起作用时才首先？

我有这条路线检查身体是否以“01”或“02”开头，并根据它调用不同的 bean。问题是只有第一个有效。例如，如果我发送以“01”开头的消息...

Azure 服务总线 Camel 组件接收控制

我们正在尝试从 Camel AMQP 组件迁移到 Camel Azure Service Bus 组件，以用于我们接收消息的服务。使用 AMQP 组件，我们可以指定 maxConcurrentConsu ...

camel splitter - 在特定异常时停止循环

我们如何在特定异常情况下停止在 camel splitter 上循环？ “stopOnException()”正在停止每个异常的循环，但我只想在某些特定的情况下停止循环...

apache camel 中的异常处理

我需要在我的骆驼路线上发送通知。有4种情况会触发它： 路线成功完成 文件丢失 第一次验证失败 第二次验证失败 他们都会送simi...

如何在 Spring Boot 或 Quarkus 中的 Apache Camel 中配置区分大小写的路径？

目前我正在将一些项目集成到 Quarkus 和 Spring Boot 中，它们都使用 Apache Camel 来构建 Rest API，但我遇到了一个罕见的问题。在 Spring Boot 中，请求似乎不...

如何在 Apache Camel 中创建 YAML DSL 路由以查询 LDAP 属性？

我正在尝试创建一个 YAML 路由来对 LDAP 服务器执行简单查询并将结果输出到日志。我的路线如下所示： - 路线： 编号：route-561c 从： uri：ti ...

Apache 骆驼“onException”不返回 JSON 响应

我正在使用 apache camel 从我的应用程序中公开 rest 端点。 当 rest 端点成功执行时，它会返回预期的 JSON 响应，如下所示。 { “key1”：“值...

获取错误springboot版本2.x到3.0.5和camel版本3.14.1到3.17.0

`要修复漏洞 CVE-2023-20860 问题在更改版本时出现以下错误 弹簧启动版本 3.0.5 17 3.17.0 `修复更改版本时出现以下错误的漏洞 CVE-2023-20860 spring-boot 版本 3.0.5 <java.version>17</java.version> <camel.version>3.17.0</camel.version> <snakeyaml.version>2.0</snakeyaml.version> Camel-cfx <version>3.17.0</version> com.chubbio.cpngadapter.processor.SetTokenInHeaderProcessor 中的字段 ctx 需要找不到类型为“org.apache.camel.CamelContext”的 bean。 注入点有如下注解： - @org.springframework.beans.factory.annotation.Autowired(required=true) 我们更改了 pom.xml 中的依赖版本` 您需要使用 Apache Camel v4 来支持 Spring Boot v3。因此，如果您使用 Camel v3，请继续使用 Spring Boot v2。

在运行时修改骆驼路线/上下文

我在我的应用程序中使用 Apache camel 作为集成框架。我正在使用 @ImportResource 注释将 CamelContext.xml 文件添加到我的应用程序中。像这样，骆驼上下文文件是...

Spring Boot Apache Camel IBM MQ 集成

如何将 IBM MQ 与 Apache Camel Spring boot 集成。是否有任何 GitHub 存储库可供参考。请帮助我。 我已经使用 spring boot apache camel 进行了开发，但是与 IBM MQ 的连接是......

使用 Quarkus 在 Apache Camel 测试中禁用 Kafka 和 Micrometer？

我们正在使用 Quarkus 2.11.3.Final 以及 camel-quarkus-micrometer，加上 quarkus-micrometer-registry-prometheus 和 camel-quarkus-microprofile-health。问题是当我们运行测试时，...