apache-camel 相关问题

pollEnrich 正在内存中加载文件并导致 EKS 部署中出现堆错误

我们有一个应用程序，它使用来自SQS的消息并根据sqs消息将文件从s3下载到文件系统。 我们使用 apache Camel 来轮询 SQS 消息队列并丰富，然后将文件下载到

如何配置Camel的jackson XmlMapper？

我有一个SpringBoot应用程序，使用Camel进行路由。 为了配置 jackson xmlMapper，我有以下 spring bean： @豆 公共 XmlMapper xmlMapper() { XmlMapper xmlMapper = 新

Camel 测试 - 无法创建路由...因为必须在进程上指定 ref

我写了这条骆驼路线： @成分 公共类 FirstRoute 扩展 RouteBuilder { 私有静态最终字符串 DIRECT_ENDPOINT = "direct:test_direct"; 私有静态最终字符串 HTTP_EN...

了解 Fuse 和 Camel 之间用于 Salesforce 集成的区别

我正在尝试学习如何进行销售人员集成，但我发现该领域的文档非常缺乏。我有一条非常简单的路线，我试图仅使用骆驼进行测试。 这是...

Apache Camel - 为什么 Rest OpenAPI 追加 basePath 两次

我有一个使用camel-rest-openapi组件来调用Petstore OpenAPI规范中定义的操作的路由。当尝试运行

使用驼峰过滤器时无法访问测试中的路由元素

我的骆驼路线定义如下： from(source).routeId("源处理器") .filter(责任消息过滤器) .log(LoggingLevel.INFO、记录器、&...

Apache Camel Quartz 在应用程序启动后立即启动，然后每小时启动

我如何配置我的骆驼石英在应用程序启动后立即触发，然后每小时触发一次。 是否有我可以使用的属性或选项来实现我的需求。 以下是我的路线

尝试在 apache 骆驼中获取原始消息时发生异常

我正在尝试在我的骆驼异常处理程序中获取原始消息。我试图调用 Exchange.getUnitOfWork().getOriginalInMessage() 但出现以下异常 java.lang.

SFTP 传输：如何按名称过滤文件

我需要从 SFTP 传输文件，我尝试使用简单的表达语言来过滤名称以及文件的最后修改日期（=今天） fromF("sftp://..." + “&过滤...

XCHANGE Apache Camel 连接到币安

如何获取使用 Apache Camel XCHANGE 的数据流？ Apache Camel XCHANGE 中有一个示例。 在此示例中，我们找到当前比特币市场价格（以 USDT 表示）： 来自（“直接：股票代码”）...

为什么apache/camel处理后会删除文件

我们正在使用Camel来读取文件并检查文件的内容。我们不需要将文件转发到端点。下面是我们用于设置 Camel 的构建。问题是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 { @覆盖 公共无效配置（）抛出异常{ 来自（“直接：开始”） ....