делают. Мне нужно отправить сообщение в очередь (RabbitMQ) после того как я добавляю в базу (MongoDB) данные. XA транзакции не хочу, но нужно обеспечить согласованность, если добавили данные в могнгу, то сообщение точно должно быть отправлени к кролику. Нужно делать какой-то шеудлер, который через таймаут проверяет добавилось ли что то новое в базу, чтобы можно было отправить сообщение?
может поможет - https://docs.mongodb.com/manual/changeStreams/
сделайте наоборот, кладите в кролика и когда вычитываете добавляйте в монгу
Обсуждают сегодня