apache-camel相关内容
我创建了一个xsd,并将其与如下所示的jaxb插件一起使用:
..
为什么此测试失败,并显示“java.lang.AssertionError:mock://Destino Receiven Message Count.Expect:<;12>但is:<;0>”?我只是想测试Camel是否真的可以对消息进行重新排序。 导入: import java.util.ArrayList; import java.util.List; import o
..
我正在从Rabb中提取消息并将其聚合。我注意到,即使在AutoAck=False的情况下,消息一旦聚合就会被确认。这意味着如果我的进程崩溃,消息将不会重新排队等待Rty。 我已经插入了Levdb Java数据库作为聚合repo,它解决了这个问题,因为我假设它只有在聚合并存储到repo中后才会确认?老实说,基于它的活动和C版本的问题,Level-db让我感觉不舒服,我想我可以将它切换到SQL re
..
我想在Spring Java应用程序中上传多个CAMEL上下文文件(camel-context.xml;camel-context2.xml)。我正在尝试以下上传文件的方式。但只有一个文件被加载。 @SpringBootApplication @ImportResource({"classpath:camel*.xml"}) 在下面的快照中,控制台蓝色标记为成功响应,红色表示错误。
..
我想知道Camel是否可以根据交换内容进行限制。 情况如下:我必须通过SOAP调用Web服务。在发送到该Web服务的参数中,有一个CustomerID。问题是,如果给定客户ID每分钟有超过1个请求,则Web服务会发回一个错误。 我想知道是否有可能使用Camel按客户ID实现节流。因此,不应对所有消息实施限制,而应仅对具有相同CustomerID的消息实施限制。 让我知道如何实现这
..
我在单元测试使用Rabbitmq作为代理的骆驼路由时遇到问题。 我已经研究了几个星期了,但还没有找到有效的方法来做到这一点。 首先,我在测试中没有调用rabbitmq时遇到了问题,并且将其保留为单元测试而不是集成测试。这是通过使用visicewith并将队列切换为模拟队列来实现的。 但是,使用以下代码时,消息不会到达结果队列或结束队列(MOBILE_QUEUE)。 java
..
我正在使用Camel进行一个简单的单元测试。我想要做的就是从一个文件(在资源下)中读取JSON内容,将其发送到Java类进行验证--这就是我正在尝试测试的方法。无论我做什么,模板(我用来sendBody(Json))总是空的。以下是我的代码: public class RouteTests extends CamelTestSupport { @EndpointInject(uri
..
我想从Apache Camel路由动态查询MongoDB集合。Apache Camel docs show how to query a collection using a constant value: from("direct:findOneByQuery") .setHeader(MongoDbConstants.CRITERIA, Filters.eq("name", "R
..
每当我的骆驼路线有正常的流量时,我就能够将身体放入下一个组件中。但是只要有异常(http 401或500),我就无法获取异常正文。我的服务器日志中刚刚出现Java异常。 我还尝试了onException()。使用它,流会出错进入其中,但是我仍然没有得到Web服务发送的错误响应体(当我直接使用postman时得到的),我只得到我发送到Web服务的正文中的请求。 同时添加路由: from(
..
我正在从 创建路由器项目. 在运行 mvn -install 时,我收到以下错误: [ERROR] 无法在项目 camel-basic 上执行目标 org.apache.felix:maven-bundle-plugin:2.3.7:bundle (default-bundle):计算项目 MavenProject 的类路径时出错:org.fusesource.example:camel-
..
我的 ftp 上有几个文件夹: /csv/xml/处理/.... 如何将每个文件从 file.csv 处理到 file.done 并将其移动到已处理文件夹后重命名和移动?我已经尝试了很多选项,比如向“from"添加大量参数,或者在 onCompletion 中添加一些东西,或者添加更多的路由来移动文件.所有占位符都包含正确的值并由 Spring 处理.
..
我有一个使用 JAVA DSL 的简单的骆驼 MINA 服务器,我的运行方式与此处记录的示例一样: 独立运行 Camel 并让它继续运行在JAVA中 MINA 2 组件 我正在尝试创建一个托管在“mina:tcp://localhost:9991"(又名 MyApp_B)的示例应用程序,它向托管在“mina:tcp://localhost:9990"的服务器发送一条非常简单的消息(又
..
我需要使用正文内容调用 rest DELETE 操作.我有其他方法可以做到这一点,但这是我们的要求.我尝试了以下方式,但无法获得输出.你能给我一个想法来实现这个吗? 这是我的代码: from("direct:start").setHeader(Exchange.HTTP_METHOD, simple("DELETE")).setHeader(Exchange.CONTENT_LENGTH,
..
from("seda:start).multicast(新 GroupedBodyAggregationStrategy()).并行处理().to("seda:process1", "seda:process2").结尾().to("seda:join"); 该计划是让 process1 和 process2 并行运行,并使其输出在连接端点上可用.如果在“direct"上,上面的工作正常,但在“
..
在探索 xml 到 json 的高效转换工具时,我发现了 AtlasMap!(https://atlasmap.io) 非常有用.AtlasMap 独立应用程序有助于制定源到目标的映射文件.它支持在 XML、JSON 和 Java 对象之间转换数据.最重要的是,我的项目严重依赖 Apache camel,它也支持骆驼组件. 虽然它对于小型有效负载工作正常,但对于大型有效负载,用于 xml 到
..
我希望将 HL7 v2(旧的 EDI 格式)消息转换为 JSON,这样我可以使它们在 Apache Drill 下可处理并在 Parquet 下可压缩. 我查看了 HAPI,但我没有找到实用程序非 XML HL7 到 JSON 的转换. 有人对图书馆有建议或参考吗? 解决方案 只需使用 HAPI 转换为 XML.下面的代码需要 Saxon,因为 XML-to-JSON 需要 X
..
使用 Apache camel 2.15.3 创建了 SOAP 服务,一切正常,甚至响应 SOAP 正文也是有效的. Camel 2.15.3 依赖于 cxf 3.0.6 但是当我将 cxf-core 更新到 3.1.3 时,一切正常,除了 SOAP 响应正文为 EMPTY. 没有错误日志,服务器正常启动. 我是否缺少一些依赖项? POM.xml
..
我有一个简单的 Hello World 示例,它将 Map 传递给 Camel,并通过 Log4J 将值显示到控制台.我想通过将 Jackson 库添加到我的 Camel applicationContext.xml 来扩展此示例以在 JSON 中呈现此地图 首先我尝试将以下 XML 标记添加到我的 applicationContext.xml(如在http://camel.apache.o
..
我正在编写 2 条路由来处理目录中的文件,这些文件可以有任何名称,但我需要 2 条路由,因为我需要一些复杂的处理. 第一条路线:
..
我正在使用 ackMode=NONE 设置骆驼路线,这意味着确认不会自动完成.如何明确确认路由中的消息? 在我的 Camel Route 定义中,我将 ackMode 设置为 NONE.根据文档,我应该能够在下游手动确认消息: https://github.com/apache/camel/blob/master/components/camel-google-pubsub/src/m
..