java - 使用 Mongo Outbound channel 适配器时如何获取 UpsertResult？

Question

我正在使用 spring 集成将数据存储在 mongo 数据库中。我使用的是java类(MongoDbStoringMessageHandler)，而不是xml配置，并且在数据库中添加一些数据时我找不到获取结果的方法...

这可能吗？怎么办？

Answer 1

MongoDbStoringMessageHandler 是一个单向组件，它不返回任何内容。

考虑使用 MongoDbOutboundGateway 代替注入(inject)的 CollectionCallback，您可以在其中执行 updateMany() 并获取 UpdateResult 作为来自此网关的回复。

请参阅引用手册中的更多信息:https://docs.spring.io/spring-integration/reference/html/mongodb.html#mongodb-outbound-gateway

更新

but I don't know what parameter to put for the function to insert the Message payload.... Since there is no reference of the message in the ServiceActivator

哦!我懂了。那是一个错误。我们无法从该上下文访问消息。请就此事提出 JIRA:https://jira.spring.io/projects/INT/

同时，作为一种解决方法，我建议您编写一个带有注入(inject)的 MongoOperations 的自定义 POJO，然后您可以针对 requestMessage 构建任何可能的逻辑。

JIRA 在这里:https://jira.spring.io/browse/INT-4570