сообщений в минуту
В этих сообщениях есть геоданные, которые надо отображать на клиенте, но надо это делать в реальном времени, т.е. когда сообщение пришло, тогда и отдать клиенту.
Есть канал который постоянно считывает данные из sqs и если нет клиента кому отдать сообщения, то просто удаляет из очереди, а если клиент(ы) есть, то он сначала им отдает, а потом уже удаляет.
Вопрос. Как сделать, чтоб запрос в webflux подключился к каналу считывания сообщений и отдавал на клиент эти сообщения, но как только http соединение прерывается, он бы отключался от канала с сообщениями?
гугли reactor + sqs
Обсуждают сегодня