apache-camel 相关问题

如何在Camel kafka选项参数中设置地图

我们在camel kafka选项中有一个名为附加属性的属性，它的类型是map 返回“kafka:”+主题+“?brokers=”+主机+“&groupId=”+组+&q...

在camel 3.x中的CamelContext中找不到方法setHandleFault(java.lang.Boolean)

我正在尝试将camel从版本2.22.2升级到3.14.10并收到以下错误： 代码： getContext().setHandleFault(Boolean.TRUE); 错误： 找不到标志 [错误]符号：方法 setHandl...

apache Camel Spring Boot 应用程序上的日志记录问题

我继承了一个 apache Camel Spring Boot 应用程序，但我在日志记录方面遇到了问题。 路由组件使用 lombok.extern.slf4j.Slf4j 注释进行注释。 正常日志正在工作

带有处理器的 Apache Camel Rest Route

我是 Apache Camel 的新手，一直在努力为 REST 端点定义路由，我打算在其中接受请求、执行一些过滤和处理并返回响应。以下是我的...

如何使用apache Camel Bindy将java pojo转换为具有列表属性的固定长度字符串？

我有一个java pojo类，如下所示？ @固定长度记录 公开课请求{ @DataField（位置= 1，长度= 15） 私有字符串 string1; @DataField（位置= 16，长度= 8） 私人

Apache Camel 通常部署为单个应用程序吗？

刚刚开始使用 Apache Camel，我正在尝试了解如何部署它。 有一个单独的 Camel 应用程序只负责从

如何检查队列是否为空，然后停止监听队列的 apache 骆驼路由

我有一个 apache 骆驼路由，它将由一个进程启动。一旦路由启动，它将处理队列上的所有消息。我想在队列清空后停止该路线，s...

“简单”表达式语言 - 算术运算符？

我在骆驼路线中使用这个表达式： .when(simple("${body.updateSeq} > ${property.PrevUpdateSeq} + 1")) .to(“直接：一些错误”) 然而它对 + 符号感到害怕。 组织.a...

测试期间未添加 Apache Camel 3.x Springboot 2.7.x 路由

我的 RouteBuilder 类 @成分 公共类 MyRouteBuilder 扩展 RouteBuilder { @覆盖 公共无效配置（）抛出异常{ 来自（“直接：开始”） ....

在 Apache Camel 中验证请求标头时如何添加自定义响应

下午好 我是 apache Camel 的新手，我正在使用 apache Camel 和 quarkus 使用微服务，我目前正在尽可能自动化地实现输入字段的验证，并在

Camel 4 的 SAXParseException

org.xml.sax.SAXParseException；行号：4268；列数：51； cos-nonambig：“http://camel.apache.org/schema/spring”：onFallback 和“http://camel.apache.org/schema/spring”：

Camel 路线在 ftp 完成之前拾取文件

我有一位客户将文件通过 ftp 传输到我们的服务器。我定义了一个路由来从此目录中选择某些文件并将它们移动到另一个目录进行处理。问题是...

优雅关机终止延迟器？

我已在路线中设置了延迟器（30000）指令。当我在此路由上执行“正常关闭”时，在这 30 秒内，消息会立即转移到下一条指令。是吗

Apache Camel：从配置文件和交换属性中读取值

我正在实现一个动态toD，其中我想在运行时使用动态值将数据发送到rabbit MQ。 值：${exchangeProperty.erpFlow} = user.create 方法 ： 我正在实现一个动态toD，其中我想在运行时使用动态值将数据发送到rabbit MQ。 价值：${exchangeProperty.erpFlow} = user.create 方法： <toD uri="rabbitmq:${properties:rabbit.uri.${exchangeProperty.erpFlow}}"/> 配置文件如下： rabbit: uri: user: create: "${rabbit.exchanges.customersDead}?${rabbit.exchangeArgs}&${rabbit.queueName}=org.user.create&concurrentConsumers=${rabbit.dlqConcurrentConsumers}&skipQueueDeclare=false" 在运行时，我期望动态 toD 看起来像， <toD uri="rabbitmq:MyExchange?exchangeType=topic&bridgeEndpoint=true&queue=org.user.create&concurrentConsumers=2&skipQueueDeclare=false"/> 期望：在运行时，应该从配置文件和交换属性中读取值。 我看到错误： Caused by: org.apache.camel.ResolveEndpointFailedException: Failed to resolve endpoint: rabbitmq:{{rabbit.uri.${exchangeProperty.erpFlow}}} due to: Property with key [rabbit.uri.${exchangeProperty.erpFlow] not found in properties from text: rabbitmq:{{rabbit.uri.${exchangeProperty.erpFlow}}} 我相信这里的问题是由于 exchangeProperty 字段造成的，因为属性占位符是在运行时实例化的。交换属性仅在实例化骆驼交换时才存在 - 这意味着只有在路由生产者中发送消息时，该属性才会包含值。 这里是一些关于如果您不使用其他框架如何将properties加载到camel的信息。 这里最好的解决方案是将 exchangeProperty.erpFlow 替换为环境变量，或者也将其放入配置属性文件中。

在 Apache Camel 路由中定义非空映射变量

我有一种情况，我想在Camel路由中定义一个非空的Map变量并将值放入其中。但我找不到办法做到这一点。 我尝试通过将 resultType 设置为“java.util.

在 JSON 和 POJO 之间使用 REST 时收到“没有类型转换器可用于从类型进行转换”

我正在定义以下端点，以便在正文中的 DTO 处接受简单的帖子。似乎仅在使用 un/marshall 语句时才有效。许多示例不使用 un/marshal 语句。 这些是……

使用Camel的spring-rabbitmq组件时如何自动声明交换？

我正在尝试从Camel 3.x迁移到Camel 4.x版本，所以我需要从rabbitmq组件迁移到替换的一个spring-rabbitmq。对于rabbitmq组件，我使用的是声明选项...

使用类型选择器时，Camel 不会从 ActiveMQ JMS 队列中消费

我正在使用camel-quarkus-activemq:3.7.0 lib和ActiveMQ:5.13.0客户端。我在没有选择器的情况下消费没有任何问题，但使用选择器它就不会消费。没有错误。我用过例子...

提取本体失败..禁类

我正在使用 Camel 和 ActiveMQ 尝试在队列之间的虚拟对象周围弹跳。 （不，在真实情况下不会这样做..） 但是，保安不允许我这样做

Camel Spring Boot Prometheus - 禁用直接组件指标

我正在尝试从 Camel Spring Boot 应用程序公开 /management/prometheus 端点。这样做时，我观察到我触发到其余端点的所有请求都被推送到