Consume messages from RabbitMQ queue using spring cloud stream 3.0+

Question

I have a Producer producing messages in a RabbitMQ queue by using a direct exchange.

queue name: TEMP_QUEUE, exchange name: TEMP_DIRECT_EXCHANGE

Producing to this queue is easy since on my producer application I use Spring AMQP which I am familiar with.

On my Consumer application, I need to use Spring cloud stream version 3.0+.

I want to avoid using legacy annotations like @EnableBinding, @StreamListener because they are about to be depracated.

Legacy code for my application would look like that :

@EnableBinding(Bindings.class)
public class TempConsumer {

    @StreamListener(target = "TEMP_QUEUE")
    public void consumeFromTempQueue(MyObject object) {
        // do stuff with the object
    }
}

public interface Bindings {
    @Input("TEMP_QUEUE")
    SubscribableChannel myInputBinding();
}

From their docs I have found out I can do something like that

@Bean
public Consumer<MyObject> consumeFromTempQueue() {
    return obj -> {
        // do stuff with the object
    };
}

It is not clear to me how do I specify that this bean will consume from TEMP_QUEUE? Also what if I want to consume from multiple queues?

Gary Russell Gary Russell · Accepted Answer · 2020-11-13T14:04:28

See Consuming from Existing Queues/Exchanges.

You can consume from multiple queues with

spring.cloud.stream.bindings.consumeFromTempQueue-in-0.destination=q1,q2,q3
spring.cloud.stream.bindings.consumer.multiplex=true

Without multiplex you'll get 3 bindings; with multiplex, you'll get 1 listener container listening to multiple queues.

Consume messages from RabbitMQ queue using spring cloud stream 3.0+

2 Answers