Build E-Commerce Apps with Reactive Programming in Spring Boot/

...

/

Crafting a REST Controller

Crafting a REST Controller

Learn about Spring AMQP and how to create a Spring WebFlux REST controller.

We'll cover the following...

Spring AMQP is dedicated to applying the “Spring way” to AMQP, a popular messaging protocol.

Adding AMQP dependency

The first step is to add Spring AMQP to our project’s build file:

XML
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-amqp</artifactId>
</dependency>
Adding Spring AMQP to the project

Defining the Spring WebFlux REST controller

Next, we need to create a Spring WebFlux REST controller class to respond to those POST calls:

Java
@RestController //1
public class SpringAmqpItemController {
    private static final Logger log = 
        LoggerFactory.getLogger(SpringAmqpItemController.class);
    private final AmqpTemplate template; //2
    public SpringAmqpItemController(AmqpTemplate template) {
        this.template = template;
    }
}
Configuring a reactive controller for AMQP messaging

Here’s a breakdown of the code above:

  1. In line 1, @RestController signals that this class focuses on consuming and rendering JSON payloads instead of rendering templates.

  2. In ...