Spring 5.0 By Example

Listening to the Rabbit Queue and consuming the Twitter API

We will consume the Twitter API, but when?

We need to start to get Tweets when the request for tracking the hashtags comes to our application. To reach that goal, we will implement the RabbitMQ Listener when the TrackedHashTag gets registered on our microservice. The application will send the message to the broker to start consuming the Twitter stream.

Let's take a look at the code and step by step understand the behaviors; the final code should look like this:

package springfive.twittergathering.domain.serviceimport org.springframework.amqp.rabbit.annotation.RabbitListenerimport org.springframework.amqp.rabbit.core.RabbitTemplateimport org.springframework.stereotype.Serviceimport ...