Apache Camel是一个功能强大的开源集成框架,基于已知的企业集成模式和强大的Bean集成
Apache Camel Quartz 在应用程序启动后立即启动,然后每小时启动
我如何配置我的骆驼石英在应用程序启动后立即触发,然后每小时触发一次。 是否有我可以使用的属性或选项来实现我的需求。 以下是我的路线
我正在尝试在我的骆驼异常处理程序中获取原始消息。我试图调用 Exchange.getUnitOfWork().getOriginalInMessage() 但出现以下异常 java.lang.
我需要从 SFTP 传输文件,我尝试使用简单的表达语言来过滤名称以及文件的最后修改日期(=今天) fromF("sftp://..." + “&过滤...
如何获取使用 Apache Camel XCHANGE 的数据流? Apache Camel XCHANGE 中有一个示例。 在此示例中,我们找到当前比特币市场价格(以 USDT 表示): 来自(“直接:股票代码”)...
我们正在使用Camel来读取文件并检查文件的内容。我们不需要将文件转发到端点。下面是我们用于设置 Camel 的构建。问题是Camel删除...
我们在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,我正在尝试了解如何部署它。 有一个单独的 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 使用微服务,我目前正在尽可能自动化地实现输入字段的验证,并在
org.xml.sax.SAXParseException;行号:4268;列数:51; cos-nonambig:“http://camel.apache.org/schema/spring”:onFallback 和“http://camel.apache.org/schema/spring”:
我有一位客户将文件通过 ftp 传输到我们的服务器。我定义了一个路由来从此目录中选择某些文件并将它们移动到另一个目录进行处理。问题是...
我正在实现一个动态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 替换为环境变量,或者也将其放入配置属性文件中。
我有一种情况,我想在Camel路由中定义一个非空的Map变量并将值放入其中。但我找不到办法做到这一点。 我尝试通过将 resultType 设置为“java.util.