監聽多個佇列

當您使用 queues 屬性時，您可以指定關聯的容器可以監聽多個佇列。您可以使用 @Header 註解，使接收訊息的佇列名稱可供 POJO 方法使用。以下範例示範如何執行此操作

@Component
public class MyService {

    @RabbitListener(queues = { "queue1", "queue2" } )
    public void processOrder(String data, @Header(AmqpHeaders.CONSUMER_QUEUE) String queue) {
        ...
    }

}

從 1.5 版開始，您可以使用屬性佔位符和 SpEL 將佇列名稱外部化。以下範例示範如何執行此操作

@Component
public class MyService {

    @RabbitListener(queues = "#{'${property.with.comma.delimited.queue.names}'.split(',')}" )
    public void processOrder(String data, @Header(AmqpHeaders.CONSUMER_QUEUE) String queue) {
        ...
    }

}

在 1.5 版之前，只能以這種方式指定單一佇列。每個佇列都需要一個單獨的屬性。