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