rabbit.groovy

package org.test

import java.util.concurrent.CountDownLatch

@Log
@Configuration
@EnableRabbitMessaging
class RabbitExample implements CommandLineRunner {

    private CountDownLatch latch = new CountDownLatch(1)

    @Autowired
    RabbitTemplate rabbitTemplate

    private String queueName = "spring-boot"

    @Bean
    Queue queue() {
        new Queue(queueName, false)
    }

    @Bean
    TopicExchange exchange() {
        new TopicExchange("spring-boot-exchange")
    }

    /**
     * The queue and topic exchange cannot be inlined inside this method and have
     * dynamic creation with Spring AMQP work properly.
     */
    @Bean
    Binding binding(Queue queue, TopicExchange exchange) {
        BindingBuilder
                .bind(queue)
                .to(exchange)
                .with("spring-boot")
    }

    @Bean
    SimpleMessageListenerContainer container(CachingConnectionFactory connectionFactory) {
        return new SimpleMessageListenerContainer(
            connectionFactory: connectionFactory,
            queueNames: [queueName],
            messageListener: new MessageListenerAdapter(new Receiver(latch:latch), "receive")
        )
    }

    void run(String... args) {
        log.info "Sending RabbitMQ message..."
        rabbitTemplate.convertAndSend(queueName, "Greetings from Spring Boot via RabbitMQ")
        latch.await()
    }

}

@Log
class Receiver {
    CountDownLatch latch

    def receive(String message) {
        log.info "Received ${message}"
        latch.countDown()
    }
}