Apache Camel是一个功能强大的开源集成框架,基于已知的企业集成模式和强大的Bean集成
Camel Body: body1 -> body2 -> body1?
我有一个消息正文。然后,我改变它。然后,我想将其重置回原始邮件正文: from("{{route:from}}") // 第 1 步 .setBody("hello world") // 第二步 .setBody...
Apache camel salesforce 组件 - 如何使用自己的连接参数启动多个路由?
我有多个 salesforce 实例,我想使用 apache camel SalesforceComponent 连接。连接参数(clientId、secret 等)仅在运行时可用,并且不同...
骆驼路由优雅关机如何在application.xml中配置DefaultShutdownStrategy
我们在 Spring Boot 上使用 Camel,我们有下面的 application.yml 属性文件来配置一些 camel 设置。 我想优雅地关闭我的应用程序和骆驼路线,所以我...
AWS EKS 上的 Quarkus 本机应用程序 - “exec 格式错误”
我正在尝试将 Quarkus-Camel 本机应用程序部署到 AWS EKS,但收到日志错误: exec ./application: exec 格式错误 该应用程序在我本地的 minikube 环境中运行良好,我确保...
我是使用 Camel Spring DSL 路由的新手。我的经验主要是使用 Java DSL。 我最近看了一个基于 Camel Spring DSL 的项目并注意到
使用 LRA 协调器的 Apache Camel Saga 配置
有人可以帮助我了解如何在 Springboot 中使用 LRA 协调器配置 Apache Camel Saga。我试过文档,但不幸的是,文档不是那么清楚,我
在 Apache Camel 中从 Google Pubsub 轮询数据时如何处理错误
我为来自 Google Pubsub 主题的投票数据开发了一个 Camel 项目。这是我的 Pubsub 路线。 from("google-pubsub:xProjectx:xTopicx?maxMessagesPerPoll=20&concurrentConsumers=10&ackMode=...
Quarkus 上的 Apache Camel - CXF SOAP - 本地主机问题:8080
我正在使用 Quarkus Apache Camel。我想使用 camel-quarkus-cxf-soap。我试过这个: https://code.quarkus.io/?e=org.apache.camel.quarkus%3Acamel-quarkus-cxf-soap&extension-search=camel-quarkus-...
如何在 CamelTestSupport 中添加模块“com.fasterxml.jackson.datatype:jackson-datatype-jsr310”
我正在创建一个扩展 CamelTestSupport 的测试。我正在使用 Apache Camel 3.10。我试图在 createRouteBuilder 的测试中设置 JavaTimeModule(), 公共 ObjectMapper
我有这个 apache 骆驼路线,我实例化一个 bean 并对传入的字符串进行一些转换但是当我将它发送到 .to(Endpoints.SEDA_SEND_PRICING_LIFE_CYCLE_MESSAGE) 它 d...
如何使用标头组合在 Apache Camel YAML DSL 中定义幂等消费者?
我正在使用带有以下 YAML DSL 路由的 Camel 主组件版本 3.19 成功地将文件从 AWS/S3 存储桶加载到本地文件系统: - 豆子: - 名称:IdempotentReposito ...
Apache Camel Exchange 对象的响应被截断
当我们升级到 spring boot 2.7.1 和 camel 版本到 3.14.6 时,其余 api 之一正在重新处理部分响应。 但是当我直接调用第三方 api 时,我们就完成了
如何确保 apache camel 一次从 AWS SQS 中选择一条消息?
最近我正在调试一个应用程序,发现我的 Apache camel 消费者一次选择两条消息并处理它们。我调试发现apache camel 正在创建两个线程
我正在从 Camel 2.X 迁移到 3.x。以前,我曾经在 Java DSL 中执行以下操作: rest().post().route().log().convertBodyTo().process().endRest(); 基本上我可以做任何我会做的事情......
我正在使用 Camel SQL。我正在尝试从 Oracle 收集数据并插入到 Snowflakes 中。 下面是代码片段。 从 (sql:select*...?dataSource=#oracleDataSource&repeatcount=1&batch=true) .
我是 Camel 的新手,我想了解它是如何工作的。 我尝试了以下示例: 公共课 CamelMainTest { public static void main(String args[]) 抛出异常{ ...
我是 Apache Camel 的初学者。我有一个具有以下结构的 Maven 项目: (https://i.stack.imgur.com/xuXV9.png) 文件 Write_Paper 包含以下内容: (https://i.stack.imgur.com/76...
我们观察到,尽管我们的 kafka 生产率很高,但我们的 Apache Camel Kafka 只能处理 100Kb/秒。我们有 6 个 kafka 分区和 6 个 Apache Camel Kafka 消费者实例....
我有连接 sftp/ftp 的骆驼路线,其中有多个文件。但是,当我执行路线时,路线正在并行读取文件夹中的所有文件。我必须处理那些文件...
您好,我正在使用 Apache Camel 和 Spring 导入文件。我只需要包含 .zip 文件,但我想排除 _ACK.zip 文件。有没有办法做到这一点? 这是我得到的 &