apache-camel相关内容

apache camel sql组件 - 如何只执行一次

我创建/创建了一个简单的 Apache Camel 程序,用于将数据从源数据库移动到目标数据库.我已经配置了一个路线来做到这一点,它的工作原理!问题是它只是每秒左右执行一次root.我只希望它执行一次. 我一直在玩定时器 repeatCount 但不能完全正确地找到根.任何人都可以帮助我尝试重新编写下面的内容,以便它只执行一次. ..
发布时间:2022-01-19 08:57:18 其他开发

Camel CXF:IllegalArgumentException 参数应为 X 类型

我正在开发一个使用 CXF 调用服务的 Camel 项目.这些服务是通过 wsdl 定义的,我无法对其进行修改.我用 wsdl2java 生成了类:我会有很多其他的远程服务,它们可能经常变化,所以我希望尽可能多地生成 POJO 和接口. 我生成的界面如下所示: @WebService(targetNamespace = "http://service.company.fr", name = ..
发布时间:2022-01-19 08:56:51 Java开发

如果一条路线配置错误,CamelContext 不会启动

我们使用 Java DSL 来配置我们的路由.路由的所有配置都在一个 db 表中,可以通过 GUI 进行配置. 如何确保 camelContext 启动,即使路由配置错误(例如,路由中的 .to(invalidurl or typo) 或只是一个错误在一条路线上)? 是否有可能在开始之前验证路线,或者可以在上下文本身上设置一些更好的参数/选项? 解决方案 可以通过.autoSt ..
发布时间:2022-01-19 08:56:02 Java开发

如何在java dsl中访问(获取)camel header

我有一个类似的代码 - //使用流式传输来增加索引吞吐量.setHeader(SolrConstants.OPERATION,常量(SolrConstants.OPERATION_INSERT_STREAMING))//定义 solr 端点和选项.to("solr://"+ getSolrEndPoint()+ "?defaultMaxConnectionsPerHost=500&streami ..
发布时间:2022-01-19 08:54:46 其他开发

如何在骆驼中延迟重试

我有兴趣在 Camel 中使用 RedeliveryPolicy 在返回某个异常时重试将消息重新传递到端点.但是我似乎找不到很多如何配置它的示例. 目前我正在尝试: from("direct:entry").onException(ResourceNotFoundException.class).redeliveryPolicy(new RedeliveryPolicy().delayP ..
发布时间:2022-01-19 08:54:21 Java开发

Camel json 验证器支持 json 草稿 07

我们使用 Apache Camel Java DSL 和 json-validator 组件来根据 json 模式验证 json 请求.当前的骆驼版本是 2.22.0,根据骆驼文档,这支持使用 NetworkNT JSON 模式库的 JSON 模式 v4、v6、v7 和 v2019-09.但是,当我尝试 JSON 架构草案 07 时,运行测试时出现错误“原因:com.networknt.schem ..
发布时间:2022-01-19 08:54:06 其他开发

骆驼从类路径资源中读取文件?

我在 Spring Boot 应用程序的“resources/file.txt"的类路径中有一个文件. 如何在骆驼路线中引用它? 我试过了: from("file:resource:classpath:?fileName=file.txt") 及其变体.似乎没有任何效果. 请问这里有什么解决方法吗? 谢谢 解决方案 您不能为此使用文件组件,因为它旨在通过 ja ..
发布时间:2022-01-19 08:53:42 其他开发

Akka Camel - JMS 消息丢失 - 应该等待 Camel 的初始化吗?

我的实验应用程序非常简单,尝试使用 Actors 和 Akka 可以做什么. 在 JVM 启动后,它创建了带有几个普通 Actor 的 Actor 系统,JMS 消费者 (akka.camel.Consumer) 和 JMS 生产者 (akka.camel.Producer).它在参与者和 JMS 生产者 -> JMS 服务器 -> JMS 消费者之间发送一些消息.它基本上通过 JMS 服务 ..
发布时间:2022-01-19 08:52:56 其他开发

apache骆驼简单表达式没有给出字符串值

我正在使用 apache 骆驼.我正在尝试使用简单的表达式语言从正文中检索值.我需要它作为字符串,但简单返回 SimpleBuilder 对象.所以我尝试过这样的事情 simple("${body.address.line}").resultType(String.class).getResultType() 但它返回给我 java.lang.String.请告诉我如何才能将这个表达式的结果作 ..
发布时间:2022-01-19 08:52:35 Java开发

为什么骆驼卡夫卡生产者很慢?

我正在使用 apache camel kafka 作为客户端来生成消息,我观察到 kafka 生产者需要 1 毫秒来推送消息,如果我使用骆驼聚合将消息合并到批处理中,那么推送单个消息需要 100 毫秒. 安装简述3 kafka 集群 16Core 32GB RAM 示例代码 String endpoint="kafka:test?topic=test&brokers=nodekfa ..
发布时间:2022-01-19 08:52:11 其他开发

Apache camel 同时处理两个 csv 文件

我正在尝试处理两个 .csv 文件并将它们的数据保存到数据库中.我使用的是 java dsl 而不是 springs. 为了更好地解释这个场景: 我正在读取两个 .csv 文件并处理它们以将它们的数据上传到 sql 数据库中.我为此执行的步骤是 在 servlet 容器文件中指定引擎初始化程序. 创建一个EngineInitialiser 将 EngineInitialiser ..
发布时间:2022-01-19 08:51:36 Java开发

Camel CXF:肥皂客户端超时

我正在使用 Camel CXF 端点连接到我的肥皂服务器.我想为来自客户的请求添加超时.我为此使用 continuationTimeout 选项.但它不起作用.请求超时,没有等待我配置的时间. 下面是我的端点配置. 解决方案 你的问题不是很清楚,因为没有骆驼路线,所以我看不出你是在骆驼内部创建 SOAP 服务还是从骆驼作为客户.根据您发送的少量信息,您似乎正在创建一个客户端. ..
发布时间:2022-01-19 08:51:28 其他开发

通过 Camel 传递统一的 Web 服务

我正在考虑在我的项目中使用 Camel,并想知道它是否可行或骆驼不是一个好的选择.我需要多个运行相同应用程序的客户端通过 Web 服务(CXF 或 AXIS)交换信息.交换将通过一个中央集线器,该集线器将执行从一个客户端到另一个客户端的基于内容的路由,并将此通信记录在数据库中.当响应进来时,集线器还会将一个客户的响应路由到另一个客户.可能会有来自多个客户的大量此类交换.网络服务完全一样,所以我不需 ..
发布时间:2022-01-19 08:51:19 其他开发