Apache Camel是一个功能强大的开源集成框架,基于已知的企业集成模式和强大的Bean集成
在 applitcation.properties 中找到的字符串中输入变量
下午好。 我目前正在使用 quarkus 和 apache Camel,我需要为不同的 http 代码返回受控错误,在 404 的情况下我需要返回以下消息...
Apache Camel 的 ${file:ext} 会拾取第一个点之后的所有内容,而不是仅拾取扩展名
正如标题所示,我正在尝试使用Camel的文件语言获取文件扩展名来指定正确的路线。 选择()。 when().simple("${file:ext} in 'xml'"). unmarshal(coreIt("jaxb[核心...
我想发送多条消息,这些消息将异步遍历同一路由,并能够知道所有处理何时完成。 因为我需要知道每条路线何时终止,所以我...
Camel Route“图表”子选项卡未显示在 HawtIO 中
在 HawtIO 中查看 Camel 路线时,我没有看到“图表”子选项卡来显示路线可视化。 这个问题在几个月前的 Camel 版本升级期间首次出现(不确定是哪个......
Apache Camel 使用新行标记进行拆分并使用聚合策略
我有以下路线: from("文件:/home/tmp/test?move=.done") .routeId("文件") .split(body().tokenize(" "),new GroupedBodyAggregationStrategy()) .亲...
Content-Type 标头无法使用 Apache Camel 到达目的地
执行路由时,内容类型标头未到达目的地。 休息配置() .host("本地主机") .端口(8082) 来自(“seda:我的路线”) .setHeader(
如何处理 onException 中的异常并传播到 Apache Camel 中的 errorHandler?
我正在运行一个案例,由于数据库中断而发生异常, 然后调用 onException 处理程序,它尝试在数据库中存储消息并更新一些状态,这
下面是我使用骆驼路由从队列中读取消息的代码片段。 from("spring-rabbitmq:{{rabbitmq.in.exchange}}?exchangeType=topic&queues={{in.dummy.queue}}"...
Apache Camel + Spring boot 异常数据格式“jaxb”无法创建
我是 Apache Camel 的新手。我的要求很简单 程序应该读取 XML 遮盖我想要的字段 生成屏蔽的 XML 我有现有的应用程序做同样的事情,但它不起作用。装箱...
在windows 10上开发。使用Win10 IIS FTP服务器。创建骆驼上下文来传输 ftp 文件。中文文件传输出现问题。目标路径中文文件乱码。 我尝试...
如何在 Camel 4 / Spring 3 / Spring Boot 6 中使用 CachingConnectionFactory
对于Camel 3,以下配置有效 Camel.component.spring-rabbitmq.connection-factory=org.springframework.amqp.rabbit.connection.CachingConnectionFactory 使用 CachingConnectionFac...
我有一个 apache 骆驼路由,它从映射条目(一个 int)中获取密钥,并在该密钥在列表中时进行选择。但我遇到了例外 .`when`(简单("\${body.key} in [123,...
我试图找到仅当消息数大于一定数量时才消费JMS队列中的消息的方法。 有任何想法吗? 通常如果您使用语法: 来自(“jms:开始曲...
在 Camel 路线中,我使用分离器来生成多个子路线。每一条路由都会使用一些外部 API 来完成一些工作,并轮询直到工作完成。我就这么远了 现在我需要触发...
在少数情况下,由于 toD(url) 导致 json 不完整
我正在使用 apache Camel 并从另一个系统拥有的数据湖中获取数据。 虽然在大多数情况下,这个流程工作得绝对正常,但对于极少数事件,我观察到
Apache Camel项目中是否可以使用触发器函数读取表中新插入的数据? 我正在使用 Apache Camel 和 PostgresDB 并在数据库中创建了触发器函数。特...
我使用AMQP Camel从队列A读取消息,向消息添加标头并发送到主题B。每300毫秒队列A中就会有200条消息。根据日志文件,JMS
需要有从kafka读取事务路由->保留在db中->发布到MQ。 所有这一切都应该在一个事务中发生,如果 DB 或 Commit to MQ/JMS 失败,那么 kafka 消息不应该是
camel-observation-starter 使用完整请求数据创建指标
我有一个使用 Camel 的 Spring Boot 3 项目。我正在使用 org.apache.camel.springboot:camel-observation-starter 进行跟踪。 我已经使用自动配置说明和来自
我知道在camel BeanIO 3.16版本之后已被弃用并从camel中删除。 我似乎找不到替代品。 我看到有些人编写自己的代码来替换它,但我很......