Я хочу создать живые уведомления для моего сайта.
Ссылка: http://sinhamohit.com/writing/spring-boot-reactive-sse
Приведенная выше ссылка содержит пример для SSE и источника события. Поток объектов создается для создания потока Flux.
В моем случае я хочу создать отправленные сервером события и отправить их на сервер RabbitMQ, а остальной контроллер должен иметь возможность прослушивать очередь сообщений и получать сообщение.
В настоящее время я могу получать сообщения, но я не уверен, как я могу преобразовать их в Flux и отправить поток на оставшийся URL.
Как мне это сделать?
Ссылки, ссылки и примеры будут отличными.