apache-camel相关内容

使用MockEndpoint测试骆驼路由

为什么此测试失败,并显示“java.lang.AssertionError:mock://Destino Receiven Message Count.Expect:<;12>但is:<;0>”?我只是想测试Camel是否真的可以对消息进行重新排序。 导入: import java.util.ArrayList; import java.util.List; import o ..
发布时间:2022-08-15 15:55:59 其他开发

聚合后的Exchange完成

我正在从Rabb中提取消息并将其聚合。我注意到,即使在AutoAck=False的情况下,消息一旦聚合就会被确认。这意味着如果我的进程崩溃,消息将不会重新排队等待Rty。 我已经插入了Levdb Java数据库作为聚合repo,它解决了这个问题,因为我假设它只有在聚合并存储到repo中后才会确认?老实说,基于它的活动和C版本的问题,Level-db让我感觉不舒服,我想我可以将它切换到SQL re ..
发布时间:2022-06-25 18:22:16 其他开发

如何在春季加载多个骆驼上下文

我想在Spring Java应用程序中上传多个CAMEL上下文文件(camel-context.xml;camel-context2.xml)。我正在尝试以下上传文件的方式。但只有一个文件被加载。 @SpringBootApplication @ImportResource({"classpath:camel*.xml"}) 在下面的快照中,控制台蓝色标记为成功响应,红色表示错误。 ..
发布时间:2022-06-25 18:07:55 其他开发

基于内容的节流

我想知道Camel是否可以根据交换内容进行限制。 情况如下:我必须通过SOAP调用Web服务。在发送到该Web服务的参数中,有一个CustomerID。问题是,如果给定客户ID每分钟有超过1个请求,则Web服务会发回一个错误。 我想知道是否有可能使用Camel按客户ID实现节流。因此,不应对所有消息实施限制,而应仅对具有相同CustomerID的消息实施限制。 让我知道如何实现这 ..
发布时间:2022-06-25 17:40:17 其他开发

单元测试骆驼/RabbitMQ路由问题

我在单元测试使用Rabbitmq作为代理的骆驼路由时遇到问题。 我已经研究了几个星期了,但还没有找到有效的方法来做到这一点。 首先,我在测试中没有调用rabbitmq时遇到了问题,并且将其保留为单元测试而不是集成测试。这是通过使用visicewith并将队列切换为模拟队列来实现的。 但是,使用以下代码时,消息不会到达结果队列或结束队列(MOBILE_QUEUE)。 java ..
发布时间:2022-06-25 17:36:53 其他开发

使用camelestSupport的CAMEL单元测试,模板始终为空

我正在使用Camel进行一个简单的单元测试。我想要做的就是从一个文件(在资源下)中读取JSON内容,将其发送到Java类进行验证--这就是我正在尝试测试的方法。无论我做什么,模板(我用来sendBody(Json))总是空的。以下是我的代码: public class RouteTests extends CamelTestSupport { @EndpointInject(uri ..
发布时间:2022-06-25 17:23:37 Java开发

Apache Camel:无法获取异常正文

每当我的骆驼路线有正常的流量时,我就能够将身体放入下一个组件中。但是只要有异常(http 401或500),我就无法获取异常正文。我的服务器日志中刚刚出现Java异常。 我还尝试了onException()。使用它,流会出错进入其中,但是我仍然没有得到Web服务发送的错误响应体(当我直接使用postman时得到的),我只得到我发送到Web服务的正文中的请求。 同时添加路由: from( ..
发布时间:2022-02-24 15:09:14 其他开发

骆驼处理后如何重命名和移动FTP上的文件?

我的 ftp 上有几个文件夹: /csv/xml/处理/.... 如何将每个文件从 file.csv 处理到 file.done 并将其移动到已处理文件夹后重命名和移动?我已经尝试了很多选项,比如向“from"添加大量参数,或者在 onCompletion 中添加一些东西,或者添加更多的路由来移动文件.所有占位符都包含正确的值并由 Spring 处理. ..
发布时间:2022-01-19 09:05:31 其他开发

阿帕奇骆驼发送一个简单的消息

我有一个使用 JAVA DSL 的简单的骆驼 MINA 服务器,我的运行方式与此处记录的示例一样: 独立运行 Camel 并让它继续运行在JAVA中 MINA 2 组件 我正在尝试创建一个托管在“mina:tcp://localhost:9991"(又名 MyApp_B)的示例应用程序,它向托管在“mina:tcp://localhost:9990"的服务器发送一条非常简单的消息(又 ..
发布时间:2022-01-19 09:05:24 Java开发

apache camel - seda 端点多播

from("seda:start).multicast(新 GroupedBodyAggregationStrategy()).并行处理().to("seda:process1", "seda:process2").结尾().to("seda:join"); 该计划是让 process1 和 process2 并行运行,并使其输出在连接端点上可用.如果在“direct"上,上面的工作正常,但在“ ..
发布时间:2022-01-19 09:04:15 其他开发

使用 AtlasMap 将 xml 转换为 json

在探索 xml 到 json 的高效转换工具时,我发现了 AtlasMap!(https://atlasmap.io) 非常有用.AtlasMap 独立应用程序有助于制定源到目标的映射文件.它支持在 XML、JSON 和 Java 对象之间转换数据.最重要的是,我的项目严重依赖 Apache camel,它也支持骆驼组件. 虽然它对于小型有效负载工作正常,但对于大型有效负载,用于 xml 到 ..
发布时间:2022-01-19 09:04:05 Java开发

将 HL7 v2 转换为 JSON

我希望将 HL7 v2(旧的 EDI 格式)消息转换为 JSON,这样我可以使它们在 Apache Drill 下可处理并在 Parquet 下可压缩. 我查看了 HAPI,但我没有找到实用程序非 XML HL7 到 JSON 的转换. 有人对图书馆有建议或参考吗? 解决方案 只需使用 HAPI 转换为 XML.下面的代码需要 Saxon,因为 XML-to-JSON 需要 X ..
发布时间:2022-01-19 09:03:57 其他开发

尝试添加杰克逊库时获取 BeanCreationException

我有一个简单的 Hello World 示例,它将 Map 传递给 Camel,并通过 Log4J 将值显示到控制台.我想通过将 Jackson 库添加到我的 Camel applicationContext.xml 来扩展此示例以在 JSON 中呈现此地图 首先我尝试将以下 XML 标记添加到我的 applicationContext.xml(如在http://camel.apache.o ..
发布时间:2022-01-19 09:03:15 Java开发