apache-camel - 使用 Camel 的 ProducerTemplate#sendBody() 发送 POJO 需要什么
问题描述
我正在尝试使用 ProducerTemplate#sendBody() 发送 POJO,但出现以下错误:
org.apache.camel.language.bean.RuntimeBeanExpressionException: Failed to invoke
method: [searchId] on app.FsiRequest due to:
java.lang.IndexOutOfBoundsException: Key: searchId not found in bean:
app.FsiRequest@5c2d65cf of type: app.FsiRequest using OGNL path [[searchId]]
at org.apache.camel.language.bean.BeanExpression.evaluate(BeanExpression.java:119) ~[camel-core-2.22.1.jar:2.22.1]
at org.apache.camel.language.bean.BeanExpression.evaluate(BeanExpression.java:135) ~[camel-core-2.22.1.jar:2.22.1]
at org.apache.camel.model.language.ExpressionDefinition.evaluate(ExpressionDefinition.java:127) ~[camel-core-2.22.1.jar:2.22.1]
at org.apache.camel.model.language.ExpressionDefinition.evaluate(ExpressionDefinition.java:119) ~[camel-core-2.22.1.jar:2.22.1]
at org.apache.camel.builder.ExpressionBuilder$40.evaluate(ExpressionBuilder.java:1004) ~[camel-core-2.22.1.jar:2.22.1]
at org.apache.camel.support.ExpressionAdapter.evaluate(ExpressionAdapter.java:36) ~[camel-core-2.22.1.jar:2.22.1]
at org.apache.camel.builder.SimpleBuilder.evaluate(SimpleBuilder.java:92) ~[camel-core-2.22.1.jar:2.22.1]
我要发送的课程(简化版):
public class FsiRequest {
public String getSearchId() {
return searchId;
}
public void setSearchId(String searchId) {
this.searchId = searchId;
}
private String searchId;
public FsiRequest(Map<String, String> request) {
searchId = request.get("searchId");
}
}
这是我的调用:
private final ForkJoinPool routeExecutorPool = new ForkJoinPool(1024);
@Override
public void configure() {
from("servlet://" + SEARCH_REQUEST)
.process(exchange -> {
FsiRequest request = createRequestMap(exchange);
sendRequestToAllProviderRoutes(exchange, request);
})
.transform()
.constant("OK");
}
private void sendRequestToAllProviderRoutes(Exchange exchange, FsiRequest request) {
try {
ProducerTemplate tmpl = exchange.getContext().createProducerTemplate();
routeExecutorPool.execute(() -> getRoutes(exchange).parallelStream().forEach(
route -> tmpl.sendBody(route, request)
));
} catch (RejectedExecutionException | RuntimeCamelException e) {
log.error("FSI Servlet failed to send request to provider routes", e);
}
}
getRoutes()
通过过滤获取相关路由exchange.getContext().getRouteDefinitions()
。
sendBody()
当我使用 aHashMap<String, Object>
而不是 FsiRequest 类时工作正常。
解决方案
这个问题是由于我们的一个错误造成的。接收路线是这样的:
.setHeader(SEARCH_ID_KEY, simple("${body[searchId]}"))
切换到body.searchId
解决问题。
推荐阅读
- python-3.x - 如何使用 keras 选择网络的预训练权重到某一层?
- c++ - 如何将 DEV C++ 中的 C++98 模式更改为支持基于范围的 for 循环的 C++17 模式?
- c# - Docker.DotNet xUnit 测试错误,无法分配请求的地址 /var/run/docker.sock
- python - STANZA/ RuntimeError: 不再支持使用 div 或 / 对张量进行整数除法
- delphi - 如何从 DLL 内部访问 DLL 中的图像?
- javascript - 简单的反应错误:不能在 Next.js 中使用 @material-ui/picker 库
- javascript - 如何在nodejs中使用弹性搜索聚合查询进行分页(从,大小)
- java - 访问 JavaFX SceneBuilder 应用程序中的字段
- ubuntu - 如何在 Ubuntu 上的 Visual Studio Code 中运行 Scheme?
- html - 我想使用 nodejs 在 mogodb 上保存 json 文件