Hands-On Microservices with Spring Boot and Spring Cloud

Configuring Spring Cloud Stream to handle challenges with messaging

To implement the event-driven create and delete services, we will use Spring Cloud Stream. In Chapter 2, Introduction to Spring Boot, in the Spring Cloud Stream section, we have already seen how easy it is to publish and consume messages on a topic using Spring Cloud Stream.

For example, to publish a message on a topic defined by mysource, we only have to write the following:

mysource.output().send(MessageBuilder.withPayload(message).build());

For consuming a message, we write the following code:

@StreamListener(target = Sink.INPUT) public void receive(MyMessage message) {   LOG.info("Received: {}",message);

This programming model can be used independently of the messaging ...