Как получить UpsertResult при использовании адаптера Mongo Outbound channel? - PullRequest
Новая
       42

Как получить UpsertResult при использовании адаптера Mongo Outbound channel?

0 голосов
/ 20 декабря 2018

Я использую пружинную интеграцию для хранения данных в базе данных Монго.Я использую классы java (MongoDbStoringMessageHandler), а не конфигурацию xml, и я не могу найти способ получить результаты при добавлении некоторых данных в базу данных ...

Возможно ли это?Как?

1 Ответ

0 голосов
/ 20 декабря 2018

MongoDbStoringMessageHandler является односторонним компонентом и ничего не возвращает.

Попробуйте использовать MongoDbOutboundGateway вместо CollectionCallback, когда вы можете выполнить updateMany() иполучить UpdateResult в качестве ответа от этого шлюза.

См. дополнительную информацию в Справочном руководстве: https://docs.spring.io/spring-integration/reference/html/mongodb.html#mongodb-outbound-gateway

ОБНОВЛЕНИЕ

но я не знаю, какой параметр поставить для функции, чтобы вставить полезную нагрузку Message .... Поскольку в ServiceActivator нет ссылки на сообщение

О!Понимаю.Это ошибка.Мы не можем получить доступ к сообщению из этого контекста.Пожалуйста, поднимите JIRA по этому вопросу: https://jira.spring.io/projects/INT/

Тем временем, в качестве обходного пути, я предлагаю вам написать пользовательское POJO с введенным MongoOperations, и вы можете построить любую возможную логику против requestMessage.

JIRA здесь: https://jira.spring.io/browse/INT-4570

...