apache-camel 相关问题

Apache Camel是一个功能强大的开源集成框架,基于已知的企业集成模式和强大的Bean集成

Apache Camel SQL 组件以批处理模式选择所有记录

我使用 apache Camel 作为从 (select *...) PostgreSQL 到 (insert...) MariaDB 的 ETL。 PostgreSQL中有很多记录(超过1M),我想以批处理的方式进行。 我尝试过

回答 1 投票 0

为什么 Hawtio UI 为空(以及 Jolokia 管理端点响应)?

我正在将 Hawtio 嵌入到我的 Camel Spring Boot 应用程序中。我按照 Hawtio 入门指南进行设置配置,但出现问题,因为当我

回答 1 投票 0

弹簧靴骆驼柱终点

我目前正在开发一个 Spring Boot Camel 项目,我已经在其中配置了一条路由。但是,当我尝试使用 cURL 或 Postman 访问路由时,我收到“404 Not Found”响应。我

回答 1 投票 0

在 applitcation.properties 中找到的字符串中输入变量

下午好。 我目前正在使用 quarkus 和 apache Camel,我需要为不同的 http 代码返回受控错误,在 404 的情况下我需要返回以下消息...

回答 1 投票 0

Apache Camel 的 ${file:ext} 会拾取第一个点之后的所有内容,而不是仅拾取扩展名

正如标题所示,我正在尝试使用Camel的文件语言获取文件扩展名来指定正确的路线。 选择()。 when().simple("${file:ext} in 'xml'"). unmarshal(coreIt("jaxb[核心...

回答 2 投票 0

如何并行消费多条消息并检测所有执行何时完成?

我想发送多条消息,这些消息将异步遍历同一路由,并能够知道所有处理何时完成。 因为我需要知道每条路线何时终止,所以我...

回答 2 投票 0

Camel Route“图表”子选项卡未显示在 HawtIO 中

在 HawtIO 中查看 Camel 路线时,我没有看到“图表”子选项卡来显示路线可视化。 这个问题在几个月前的 Camel 版本升级期间首次出现(不确定是哪个......

回答 1 投票 0

Apache Camel 使用新行标记进行拆分并使用聚合策略

我有以下路线: from("文件:/home/tmp/test?move=.done") .routeId("文件") .split(body().tokenize(" "),new GroupedBodyAggregationStrategy()) .亲...

回答 1 投票 0

Content-Type 标头无法使用 Apache Camel 到达目的地

执行路由时,内容类型标头未到达目的地。 休息配置() .host("本地主机") .端口(8082) 来自(“seda:我的路线”) .setHeader(

回答 1 投票 0

如何处理 onException 中的异常并传播到 Apache Camel 中的 errorHandler?

我正在运行一个案例,由于数据库中断而发生异常, 然后调用 onException 处理程序,它尝试在数据库中存储消息并更新一些状态,这

回答 1 投票 0

如何使用骆驼路由每 4 小时从队列中读取消息

下面是我使用骆驼路由从队列中读取消息的代码片段。 from("spring-rabbitmq:{{rabbitmq.in.exchange}}?exchangeType=topic&queues={{in.dummy.queue}}"...

回答 1 投票 0

Apache Camel + Spring boot 异常数据格式“jaxb”无法创建

我是 Apache Camel 的新手。我的要求很简单 程序应该读取 XML 遮盖我想要的字段 生成屏蔽的 XML 我有现有的应用程序做同样的事情,但它不起作用。装箱...

回答 1 投票 0

camel-ftp:目标文件名编码错误

在windows 10上开发。使用Win10 IIS FTP服务器。创建骆驼上下文来传输 ftp 文件。中文文件传输出现问题。目标路径中文文件乱码。 我尝试...

回答 1 投票 0

如何在 Camel 4 / Spring 3 / Spring Boot 6 中使用 CachingConnectionFactory

对于Camel 3,以下配置有效 Camel.component.spring-rabbitmq.connection-factory=org.springframework.amqp.rabbit.connection.CachingConnectionFactory 使用 CachingConnectionFac...

回答 1 投票 0

Apache Camel 简单解析异常

我有一个 apache 骆驼路由,它从映射条目(一个 int)中获取密钥,并在该密钥在列表中时进行选择。但我遇到了例外 .`when`(简单("\${body.key} in [123,...

回答 1 投票 0

Apache Camel - 仅当队列大小大于

我试图找到仅当消息数大于一定数量时才消费JMS队列中的消息的方法。 有任何想法吗? 通常如果您使用语法: 来自(“jms:开始曲...

回答 1 投票 0

Camel:生成多条路线,等待所有路线完成

在 Camel 路线中,我使用分离器来生成多个子路线。每一条路由都会使用一些外部 API 来完成一些工作,并轮询直到工作完成。我就这么远了 现在我需要触发...

回答 1 投票 0

在少数情况下,由于 toD(url) 导致 json 不完整

我正在使用 apache Camel 并从另一个系统拥有的数据湖中获取数据。 虽然在大多数情况下,这个流程工作得绝对正常,但对于极少数事件,我观察到

回答 2 投票 0

Apache Camel 项目 - 通知/监听 sql

Apache Camel项目中是否可以使用触发器函数读取表中新插入的数据? 我正在使用 Apache Camel 和 PostgresDB 并在数据库中创建了触发器函数。特...

回答 1 投票 0

消息消费者每1秒关闭一次

我使用AMQP Camel从队列A读取消息,向消息添加标头并发送到主题B。每300毫秒队列A中就会有200条消息。根据日志文件,JMS

回答 1 投票 0

© www.soinside.com 2019 - 2024. All rights reserved.