spring-amqp-utils

Maven

<dependency>
    <groupId>com.avides.spring</groupId>
    <artifactId>spring-amqp-utils</artifactId>
    <version>1.0.1.RELEASE</version>
</dependency>

Available methods

AmpqUtils.buildDurableQueueWithDlx(String queueName, AmqpAdmin adminThatShouldDeclare)
AmpqUtils.buildDurableQueueWithDlx(String queueName, AmqpAdmin adminThatShouldDeclare, AmqpAdmin... furtherAdminsThatShouldDeclare)

AmpqUtils.buildDurableQueueWithDlxArguments(String queueName, AmqpAdmin adminThatShouldDeclare)
AmpqUtils.buildDurableQueueWithDlxArguments(String queueName, AmqpAdmin adminThatShouldDeclare, AmqpAdmin... furtherAdminsThatShouldDeclare)

AmpqUtils.buildDurableDlxQueueFor(Queue queue)
AmpqUtils.buildDurableDlxQueueFor(String queueName, AmqpAdmin adminThatShouldDeclare)
AmpqUtils.buildDurableDlxQueueFor(String queueName, AmqpAdmin adminThatShouldDeclare, AmqpAdmin... furtherAdminsThatShouldDeclare)

AmpqUtils.buildNonDurableQueueWithDlx(String queueName, AmqpAdmin adminThatShouldDeclare)
AmpqUtils.buildNonDurableQueueWithDlx(String queueName, AmqpAdmin adminThatShouldDeclare, AmqpAdmin... furtherAdminsThatShouldDeclare)

AmpqUtils.buildNonDurableQueueWithDlxArguments(String queueName, AmqpAdmin adminThatShouldDeclare)
AmpqUtils.buildNonDurableQueueWithDlxArguments(String queueName, AmqpAdmin adminThatShouldDeclare, AmqpAdmin... furtherAdminsThatShouldDeclare)

AmpqUtils.buildNonDurableDlxQueueFor(Queue queue)
AmpqUtils.buildNonDurableDlxQueueFor(String queueName, AmqpAdmin adminThatShouldDeclare)
AmpqUtils.buildNonDurableDlxQueueFor(String queueName, AmqpAdmin adminThatShouldDeclare, AmqpAdmin... furtherAdminsThatShouldDeclare)

AmqpUtils.buildDlxQueueFor(Queue queue)

Examples

Possibility 1

@Configuration
@EnableRabbit
public class RabbitConfiguration
{
    @Bean
    public Exchange exchange()
    {
        return new TopicExchange("exchange.name");
    }

    @Bean
    public Queue queue(AmqpAdmin amqpAdmin)
    {
        return AmqpUtils.buildDurableQueueWithDlx("queue.name", amqpAdmin);
    }
    
    @Bean
    public Binding binding(AmqpAdmin amqpAdmin)
    {
        return bind(queue(amqpAdmin)).to(exchange()).with("routing.key").noargs();
    }
}

Possibility 2

If you want to have access to the DLX-Queue-Bean

@Configuration
@EnableRabbit
public class RabbitConfiguration
{
    @Bean
    public Exchange exchange()
    {
        return new TopicExchange("exchange.name");
    }

    @Bean
    public Queue queue(AmqpAdmin amqpAdmin)
    {
        return AmqpUtils.buildDurableQueueWithDlxArguments("queue.name", amqpAdmin);
    }
    
    @Bean
    public Queue dlxQueue(AmqpAdmin amqpAdmin)
    {
        return AmqpUtils.buildDlxQueueFor(queue(amqpAdmin));
    }
    
    @Bean
    public Binding binding(AmqpAdmin amqpAdmin)
    {
        return bind(queue(amqpAdmin)).to(exchange()).with("routing.key").noargs();
    }
}

Possibility 3

The same as possibility 2, but referncing the Queue and the DLX-Queue via the queue-name

@Configuration
@EnableRabbit
public class RabbitConfiguration
{
    @Bean
    public Exchange exchange()
    {
        return new TopicExchange("exchange.name");
    }

    @Bean
    public Queue queue(AmqpAdmin amqpAdmin)
    {
        return AmqpUtils.buildDurableQueueWithDlxArguments("queue.name", amqpAdmin);
    }
    
    @Bean
    public Queue dlxQueue(AmqpAdmin amqpAdmin)
    {
        return AmqpUtils.buildDurableDlxQueueFor("queue.name", amqpAdmin);
    }
    
    @Bean
    public Binding binding(AmqpAdmin amqpAdmin)
    {
        return bind(queue(amqpAdmin)).to(exchange()).with("routing.key").noargs();
    }
}

In all given examples, it is also possible to give more than one RabbitAdmin/AmqpAdmin that should declare the queues. Also all examples can be made with non-durable-queues (use the AmqpUtils.buildNonDurable...-methods)