Spring 5.0 Cookbook

How to do it...

Let's implement a direct reply-to communication using the AMQP protocol by following these steps:

1. Open the first message consumer, the Login Microservice project. Disable the previous RabbitMQConfig for blocking send-receive communication and replace it with RabbitMQEventConfig as follows. Obviously, the following class only contains the queue and no exchange binding setup:

@Configuration 
@EnableWebFlux 
@EnableRabbit 
public class RabbitMQEventConfig { 
    
   @Bean 
    public Queue queue() { 
        return new Queue("login.packt.retrieval.msg"); 
    } 
 
} 

2. Then, disable the configuration for the synchronous send-receive and replace it with the following exchange-queue binding configuration:

@Configuration @EnableWebFlux @EnableRabbit public class ...