Developing Java Applications with Spring and Spring Boot

Filtering streams

We are receiving the messages from RabbitMQ. Now, we need to return the messages to the connected customer.

For that, we will use SSE with Spring WebFlux. The solution is a good fit for us because we will produce a Flux<Tweet> and start to push the Tweets for our clients. The clients will send a query to filter the desired Tweets.

The application will be fully reactive. Let's take a look at our code:

package springfive.twitterdispatcher.domain.controllerimport org.springframework.http.MediaTypeimport org.springframework.web.bind.annotation.GetMappingimport org.springframework.web.bind.annotation.RequestMappingimport org.springframework.web.bind.annotation.RequestParamimport org.springframework.web.bind.annotation.RestController ...