容器和 Broker 命名的佇列

雖然最好使用 AnonymousQueue 例項作為自動刪除佇列，但從 2.1 版本開始，您可以將 Broker 命名的佇列與監聽器容器一起使用。以下示例顯示瞭如何執行此操作

@Bean
public Queue queue() {
    return new Queue("", false, true, true);
}

@Bean
public SimpleMessageListenerContainer container() {
    SimpleMessageListenerContainer container = new SimpleMessageListenerContainer(cf());
    container.setQueues(queue());
    container.setMessageListener(m -> {
        ...
    });
    container.setMissingQueuesFatal(false);
    return container;
}

請注意名稱的空 String。當 RabbitAdmin 宣告佇列時，它會使用 Broker 返回的名稱更新 Queue.actualName 屬性。配置容器時，必須使用 setQueues() 才能使其工作，以便容器可以在執行時訪問宣告的名稱。僅設定名稱是不夠的。

您不能在容器執行時將 Broker 命名的佇列新增到容器中。

當連線重置並建立新連線時，新佇列會獲得一個新名稱。由於容器重新啟動和佇列重新宣告之間存在競爭條件，因此將容器的 missingQueuesFatal 屬性設定為 false 非常重要，因為容器很可能最初嘗試重新連線到舊佇列。