- Java 双重比较
- java - 比较器与 Apache BeanComparator
- Objective-C 完成 block 导致额外的方法调用?
- database - RESTful URI 是否应该公开数据库主键?
这就是我想要做的。我必须读取两个包含此内容的文件
<Person>
<Requestor>Dinesh</Requestor>
</Person>
为此我创建了一条路线
<route id="getPerson">
<from uri="file:src/main/resources/xml?noop=true"/>
</route>
接下来我需要读取另一个名为 Address 的文件
<Address>
<City>New York </City>
</Address>
这是我的第二条路线
<route id="getAddress">
<from uri="file:src/main/resources/xmlAddress?noop=true"/>
</route>
如何使用 Enricher 或 Aggregate 将这两个 xml 合并为一个,使最终的 xml 消息看起来像这样
<Person>
<Requestor>Dinesh</Requestor>
<Address>
<City>New York</City>
</Address>
</Person>
有什么想法吗?我尝试按照文档进行操作,但它所说的只是发送到某些 Web 服务 uri。
上面的场景是我实际想要做的事情的简化版本。对我来说,现实生活中的情况是这样做——步骤 1. 读取一个 xml 文件,第 2 步:调用 Web 服务并获得响应。第3步:合并第2步中的Response,并在第1步中将其添加到Xml body
编辑 1: 我可以编写自定义 AggregatorStartegy 类。我写了这样的东西
public class AggregationStrategy implements org.apache.camel.processor.aggregate.AggregationStrategy{
@Override
public Exchange aggregate(Exchange oldExchange, Exchange newExchange) {
newExchange.getOut().setBody("<all>"
+ oldExchange.getIn().getBody(String.class)
+ newExchange.getIn().getBody(String.class)
+ "</all>");
return newExchange;
}
}
我正在苦苦挣扎的是如何编写 Spring xml,我可以在这里告诉我的消息或文件 1+ 消息或文件 2,加入他们吧。这是我实际的 context.xml 的样子
<camelContext id="myCamel" xmlns="http://camel.apache.org/schema/spring">
<route>
<from uri="file:src/main/resources/xmlPerson?noop=true"/>
<camel:to uri="direct:enrichMessage"></camel:to>
</route>
<route >
<from uri="file:src/main/resources/xmlAddress?noop=true"/>
<log message="**************RESPONSE FROM CATASK DSS:: \n ${body}" id="log_output"/>
<camel:to uri="direct:enrichMessage"></camel:to>
</route>
<route id="enrichMessage">
<from uri="direct:enrichMessage"/>
<camel:enrich strategyRef="aggregationBean" />
<log message="**************MERGED RESPONSE :: \n ${body}"/>
</route>
最佳答案
我终于明白了。我最初的理解是我们可以手头有两条消息并将它们合并为 Ex -路线 1 最终消息 -
迪内什
路线 2 最终消息 -
<Address>
<city>New York</city>
</Address>
我的理解是,在收到上面的两条消息后,我可以构建一个 aggregationStartegy 并将它们合并。好吧,我的假设是错误的。 enricher 的工作方式是它手头有一条消息,在它从第二条路线获取消息之前,我们需要告诉 Camel - “嘿,在你收到路线 2 的消息之前,这是来自路线 1 的消息。当你获取来自Route 1的消息,使用我的聚合策略类将它们合并“。”
所以我期待在使用 Enricher 后会出现以下结果
<Person>
<name>Dinesh</name>
</Person>
<Address>
<city>New York</city>
</Address>
但我不确定该怎么做。这是我正在做的,这是错误的方法
<route id="getPerson">
<from uri="file:src/data/catask/person?noop=true" />
<to uri="direct:enrich"/>
</route>
<route id="getAddress">
<from uri="file:src/data/catask/address?noop=true" />
<to uri="direct:enrich"/>
</route>
<route id="enrich">
<from uri="direct:enrich"/>
<enrich strategyRef="aggregationBean"/>
<log message="After Merge ... ${body}"/>
</route>
<bean id="aggregationBean" class="com.mycompany.camel.canadatask.AggregationStrategy"/>
我的 Java 类看起来像这样
public class AggregationStrategy implements
org.apache.camel.processor.aggregate.AggregationStrategy{
@Override
public Exchange aggregate(Exchange message,Exchange resource) {
String old = resource.getIn().getBody(String.class);
System.out.println("OLD:: \n"+old);
String newMsg = message.getIn().getBody(String.class);
System.out.println("NEW:: \n"+newMsg);
System.out.println("MERGED::" + old + newMsg);
message.getIn().setBody(old+newMsg);
return message;
}
}
现在上面的代码当然不起作用了。后来我意识到了错误,我对enricher的理解是错误的。
正确的实现是这样的-
<route id="getPerson">
<from uri="file:src/data/catask/person?noop=true" />
<pollEnrich strategyRef="aggregationBean" uri="file:src/data/catask/address?noop=true"/>
<log message="After Merge ... ${body}"/>
</route>
<bean id="aggregationBean" class="com.mycompany.camel.canadatask.AggregationStrategy"/>
Java 代码保持不变 -
public class AggregationStrategy implements
org.apache.camel.processor.aggregate.AggregationStrategy{
@Override
public Exchange aggregate(Exchange message,Exchange resource) {
String old = resource.getIn().getBody(String.class);
System.out.println("OLD:: \n"+old);
String newMsg = message.getIn().getBody(String.class);
System.out.println("NEW:: \n"+newMsg);
System.out.println("MERGED::" + old + newMsg);
message.getIn().setBody(old+newMsg);
return message;
}
}
关于java - Apache Camel 合并来自不同路径的两个文件,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/21167348/
BufferedImage image = ImageIO.read(SpriteSheet.class.getResource(path)); BufferedImage image = Image
希望有人能够帮助我解决将我的 React 应用程序推送到 Heroku 时遇到的问题。 heroku 日志反复显示以下错误。 at=error code=H10 desc="App crashed"
我是 Kotlin 的新手,我正在经历这样的例子。 . . package com.example.lambda1 import spark.Spark.get fun main(args: Arra
如果您已经安装了 32 位 JDK,请在中定义一个 JAVA_HOME 变量 Computer>System Properties>System Setting>Enviorment VAriable
我正在开发一个独立于平台的应用程序。我收到一个文件 URL*。在 Windows 上,这些是: file:///Z:/folder%20to%20file/file.txt file://host/f
我在 OSX、Objective-C 上。 我有一个像 这样的路径/NSURL /Users/xxx/Desktop/image2.png 但我将它传递给第三方应用程序,该应用程序会像 excpect
我已经安装了 Android studio 和插件的 DART,FLUTTER 来启动 flutter,但是因为我在创建我的第一个 flutter 项目时无法提供 sdk 路径。 最佳答案 我试图找出
127.0.0.1:8000/api/仅包含来自第二个应用程序的 url,但我将两个 url 模块链接到相同的模式。甚至有可能做到这一点吗? 第一个应用程序: from django.urls imp
对于大量图像(大约 1k,加上相同数量的拇指,在大约 500 个文件夹中),我们要求网站上使用的所有图像 URI 都必须具有 SEO 优化路径。它们已经准备好并提供完整的路径结构(每个文件夹包含一个具
为什么 f 不是一个文件?什么可能导致这种情况? String currentPhotoPath = "file:/storage/sdcard0/Pictures/someFileName.
Gradle 中的项目名称或路径中允许使用哪些字符? 它是否与特定操作系统的目录名称中允许的字符相同(例如: http://en.wikipedia.org/wiki/Filename#Reserve
我有一个包含文件夹路径的表格。我需要找到层次结构中这些文件夹之间的所有“差距”。我的意思是,如果表格包含这 3 个文件夹: 'A' 'A\B\C' 'A\B\C\D\E\F\G' 我需要在层次结构中找
我在 Linux 服务器上的/home/subversion 中安装了 svn - 那里有一个 ROOT 文件夹,其中包含 db 和 conf 等文件夹。没有映射到项目名称的文件夹,请有人告诉我如何列
对于我的图像位置:/src/assets/bitmap/sample.jpg 给出了关键配置: context: resolve('src') output: { path: resolve('b
我需要创建带有圆角的 SVG 路径,以将它们导出到 DXF 进行切割。我的问题是角应该是圆弧,而不是贝塞尔曲线。 使用 arc 命令相对容易处理直角,因为半径也是从拐角到圆弧起点的距离。对于其他角度,
大家好,我正在玩 Airflow,我正在阅读这篇很有帮助的 tutorial .我正在寻求帮助以更好地了解 Admin->Connection 如何在 Conn Type: File (path) 方
我的目标是定义R将用于安装和搜索库的单个路径。我read可以通过更改Rprofile.site安装路径中的R文件来完成。我在那里尝试了两个命令: .libPaths("D:/RLibrary") .L
我有一个问题:当我在一个页面中时,我想返回到上一页。我使用 $routeProvider。如何读取之前的 url? 我尝试在我的 Controller 中使用此代码但不起作用... angular.m
我正在尝试将一个文件从我的主干合并到一个分支(wc),并且对于看起来位于当前合并操作中不涉及的分支上的路径出现奇怪的未找到路径错误。 例如,在我们的 svn 项目中,我们有: 分行 分支 0 分支 1
我有一个树数据序列化如下: 关系:P到C是“一对多”,C到P是“一对一”。所以列 P 可能有重复的值,但列 C 有唯一的值。 P, C 1, 2 1, 3 3, 4 2, 5 4, 6 # in da
我是一名优秀的程序员,十分优秀!