apache-camel相关内容
我创建/创建了一个简单的 Apache Camel 程序,用于将数据从源数据库移动到目标数据库.我已经配置了一个路线来做到这一点,它的工作原理!问题是它只是每秒左右执行一次root.我只希望它执行一次. 我一直在玩定时器 repeatCount 但不能完全正确地找到根.任何人都可以帮助我尝试重新编写下面的内容,以便它只执行一次.
..
我正在开发一个使用 CXF 调用服务的 Camel 项目.这些服务是通过 wsdl 定义的,我无法对其进行修改.我用 wsdl2java 生成了类:我会有很多其他的远程服务,它们可能经常变化,所以我希望尽可能多地生成 POJO 和接口. 我生成的界面如下所示: @WebService(targetNamespace = "http://service.company.fr", name =
..
我们使用 Java DSL 来配置我们的路由.路由的所有配置都在一个 db 表中,可以通过 GUI 进行配置. 如何确保 camelContext 启动,即使路由配置错误(例如,路由中的 .to(invalidurl or typo) 或只是一个错误在一条路线上)? 是否有可能在开始之前验证路线,或者可以在上下文本身上设置一些更好的参数/选项? 解决方案 可以通过.autoSt
..
我有一个简单的骆驼应用程序在计时器上记录事件.日志当前转到 ConsoleAppender. 我已尝试按照以下文档进行操作:http://hawt.io/plugins/logs/ 该应用程序部署为对码
..
我有一个类似的代码 - //使用流式传输来增加索引吞吐量.setHeader(SolrConstants.OPERATION,常量(SolrConstants.OPERATION_INSERT_STREAMING))//定义 solr 端点和选项.to("solr://"+ getSolrEndPoint()+ "?defaultMaxConnectionsPerHost=500&streami
..
我最近在尝试将 XML 传递给 apache Camel 中的 Cxf Webservice 时遇到了这个问题. Caused by: java.lang.IllegalArgumentException: Get wrong parameter size to invoke out service, Expect size 1, Parameter size 2. 请检查消息体是否匹配CXF
..
我有兴趣在 Camel 中使用 RedeliveryPolicy 在返回某个异常时重试将消息重新传递到端点.但是我似乎找不到很多如何配置它的示例. 目前我正在尝试: from("direct:entry").onException(ResourceNotFoundException.class).redeliveryPolicy(new RedeliveryPolicy().delayP
..
我们使用 Apache Camel Java DSL 和 json-validator 组件来根据 json 模式验证 json 请求.当前的骆驼版本是 2.22.0,根据骆驼文档,这支持使用 NetworkNT JSON 模式库的 JSON 模式 v4、v6、v7 和 v2019-09.但是,当我尝试 JSON 架构草案 07 时,运行测试时出现错误“原因:com.networknt.schem
..
我在 Spring Boot 应用程序的“resources/file.txt"的类路径中有一个文件. 如何在骆驼路线中引用它? 我试过了: from("file:resource:classpath:?fileName=file.txt") 及其变体.似乎没有任何效果. 请问这里有什么解决方法吗? 谢谢 解决方案 您不能为此使用文件组件,因为它旨在通过 ja
..
我创建了一个小的 Apache Camel 示例,但它找不到类 org.apache.camel.impl.DefaultComponent.这里完整的错误日志. 我已经在 搜索.maven.org,表示它应该包含在 org.apache.camel:camel-core 中.添加它并不能解决我的问题.这个例子有什么问题? 这是应用程序 @SpringBootApplication公
..
我有一个骆驼路由,它处理来自 process queue 的消息并将其发送到 upload queue. from("activemq:queue:process" ).routeId("activemq_processqueue").process(交换-> {SomeImpl impl = new SomeImpl();impl.process(交换);}).to(ExchangePatte
..
我的实验应用程序非常简单,尝试使用 Actors 和 Akka 可以做什么. 在 JVM 启动后,它创建了带有几个普通 Actor 的 Actor 系统,JMS 消费者 (akka.camel.Consumer) 和 JMS 生产者 (akka.camel.Producer).它在参与者和 JMS 生产者 -> JMS 服务器 -> JMS 消费者之间发送一些消息.它基本上通过 JMS 服务
..
我正在使用 apache 骆驼.我正在尝试使用简单的表达式语言从正文中检索值.我需要它作为字符串,但简单返回 SimpleBuilder 对象.所以我尝试过这样的事情 simple("${body.address.line}").resultType(String.class).getResultType() 但它返回给我 java.lang.String.请告诉我如何才能将这个表达式的结果作
..
如果这样做的话,这里是:body ->字符串->用户 .to("direct:httpClient").process(新处理器(){@覆盖公共无效进程(交换交换)抛出 JsonProcessingException {String body = exchange.getIn().getBody(String.class);User[] users = jacksonDataFormat.ge
..
我正在使用 apache camel kafka 作为客户端来生成消息,我观察到 kafka 生产者需要 1 毫秒来推送消息,如果我使用骆驼聚合将消息合并到批处理中,那么推送单个消息需要 100 毫秒. 安装简述3 kafka 集群 16Core 32GB RAM 示例代码 String endpoint="kafka:test?topic=test&brokers=nodekfa
..
我正在尝试处理两个 .csv 文件并将它们的数据保存到数据库中.我使用的是 java dsl 而不是 springs. 为了更好地解释这个场景: 我正在读取两个 .csv 文件并处理它们以将它们的数据上传到 sql 数据库中.我为此执行的步骤是 在 servlet 容器文件中指定引擎初始化程序. 创建一个EngineInitialiser 将 EngineInitialiser
..
我正在使用 Camel CXF 端点连接到我的肥皂服务器.我想为来自客户的请求添加超时.我为此使用 continuationTimeout 选项.但它不起作用.请求超时,没有等待我配置的时间. 下面是我的端点配置. 解决方案 你的问题不是很清楚,因为没有骆驼路线,所以我看不出你是在骆驼内部创建 SOAP 服务还是从骆驼作为客户.根据您发送的少量信息,您似乎正在创建一个客户端.
..
我正在考虑在我的项目中使用 Camel,并想知道它是否可行或骆驼不是一个好的选择.我需要多个运行相同应用程序的客户端通过 Web 服务(CXF 或 AXIS)交换信息.交换将通过一个中央集线器,该集线器将执行从一个客户端到另一个客户端的基于内容的路由,并将此通信记录在数据库中.当响应进来时,集线器还会将一个客户的响应路由到另一个客户.可能会有来自多个客户的大量此类交换.网络服务完全一样,所以我不需
..
我有一条看起来像下一条的骆驼路线: from("direct:download").pollEnrich().simple("sftp://my.host:22/folder/?username=foo&fileName=${header.CamelFileName}&privateKeyFile=src/main/resources/privateSSHKey").to("file://sta
..
我在我的项目中使用 Spring MVC 和 Camel,但遇到了 producerTemplate 无法自动装配的问题.请在下面查看详细信息, 文件 web.xml: contextConfigLocation/WEB-INF/dispatcher-servlet.xml 文件 ispatcher-
..