我正在尝试使用 apache Camel 在 MongoDB 中保存一些数据。以下是我的代码
from("direct:saveData")
.process(dataSaveRequestProcessor)
.streamCaching()
.to("mongodb:emailDB?database=myDB&collection=myData&operation=save&writeConcern=safe&writeResultAsHeader=true")
.process(dataSaveResponseProcessor);
现在问题是保存在 MongoDB 记录中，但它没有返回到我的响应处理器。我需要在 MongoDB 中生成的 _id 传递给另一个路由。
以下是响应处理器中的 System.out
===============> OUT BODY : null
===============> OUT BODY HEADER: {}
===============> IN BODY : { "serverUsed" : "/127.0.0.1:27017" , "n" : 0 , "connectionId" : 22 , "err" : null , "ok" : 1.0}
===============> IN BODY HEADER : {CamelMongoWriteResult={ "serverUsed" : "/127.0.0.1:27017" , "n" : 0 , "connectionId" : 22 , "err" : null ,
“ok”：1.0}，CamelMongoDbLastError={“serverUsed”：“/127.0.0.1:27017”，“n”：0，“connectionId”：22，“err”：null，“ok”：1.0}}
任何人都可以指出我在哪里犯错。为什么exchange.getIN().getBody()中没有 _id
先感谢您