How to integrate RabbitMQ with Spring Boot?

1
2
3
4

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-amqp</artifactId>
</dependency>

1
2
3
4

spring.rabbitmq.host=localhost
spring.rabbitmq.port=5672
spring.rabbitmq.username=guest
spring.rabbitmq.password=guest

1
2
3
4
5

@Configuration
@EnableRabbit
public class RabbitMQConfig {
    //...
}

1
2
3
4
5
6

@Bean
public SimpleRabbitListenerContainerFactory rabbitListenerContainerFactory(ConnectionFactory connectionFactory) {
    SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory();
    factory.setConnectionFactory(connectionFactory);
    return factory;
}

1
2
3
4
5
6
7

@Component
public class RabbitMQListener {
    @RabbitListener(queues = "queue-name")
    public void processMessage(String message) {
        //...
    }
}