apache-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 端点。这样做时，我观察到我触发到其余端点的所有请求都被推送到

无法设置 Apache Camel SMPP 以使用 GSM-7 从 SMSC 节点接收消息

这个问题是关于 Apache Camel SMPP 和 GSM-7 使用camel-smpp-starter 4.2.0 我们的 SMSC 根据标头使用 SMSC 默认字母表向我们的应用程序发送短信。这是根据...

直接在camel路由中归档，无需文件消费者

有没有办法让骆驼删除不是来自文件使用者的文件？ 更准确地说：在我的路线中，我收集了一个文件列表（不是来自文件组件），然后对其进行处理。啊...

在 Camel 2.12 中禁用 Camel 证书验证

我需要在 Camel 2.12 中暂时禁用证书验证。我正在引用一个测试 Web 服务，该服务当前提供无效证书并获得以下信息

Flaky Consumer 无法在 Camel 和 Spring 中消费消息（~ 1%）

我正在使用 ProducerTemplate 和 ConsumerTemplate 来处理简单路由测试中的消息发送和接收。我还使用带有 activeMQ 图像的 testcontainer 。下面有一个设置： @

Apache Camel 文件上传目录变得重复

最终字符串 sftpEndpoint = "sftp://{{sftp.write.host}}" + ":" + "{{sftp.write.port}}" +“{{sftp.write.folder}}” +“？使用...

在运行时加载 apache 骆驼路由

在项目中，我一直在运行时动态加载 Apache Camel 路由。 当前环境包括 Spring 2.7.4、Apache Camel 3.18.0 和 JDK 17 private void fromFile(最终路径文件...