Spring AMQP - ничего не отображается в очереди мертвых букв

Question

У меня есть то, что кажется правильно настроенной очередью RabbitMQ (показывает аргумент dlx), и в моем коде слушателя Java я бросаю FatalListenerExecutionException. По какой-то причине ничего не появляется в заданной очереди мертвых букв после того, как выбрано исключение.

Я бросаю неправильное исключение?

Спасибо.

Очередь конкретизации в конфигурации Spring:

Map arguments = new HashMap(); 
arguments.put("x-dead-letter-exchange", "dlx.queue"); 
new Queue("some.queue", true, false, false, arguments); 

Слушатель Контейнер в конфигурации Spring:

public SimpleMessageListenerContainer 
someContainer(){ 
     final SimpleMessageListenerContainer container = new SimpleMessageListenerContainer(); 
     container.setConnectionFactory(connectionFactory); 
     container.setQueues(createTheQueue()); 
     container.setMessageListener(theListener()); 
     container.setConcurrentConsumers(numberOfConcurrentConsumers); 
     container.setMaxConcurrentConsumers(maxDefaultConsumers); 
     container.setDefaultRequeueRejected(false); 
     return container; 
    } 

Наручники для "some.queue", показанной на RabbitMQ консоли:

Parameters : x-dead-letter-exchange: dlx.queue 

Answer 1

You должен выбросить AmqpRejectAndDontRequeueException или достаточно установить defaultRequeuRejected="false" для контейнера-слушателя.

Смотрите тест-случай с весны AMQP: https://github.com/spring-projects/spring-amqp/blob/master/spring-rabbit/src/test/java/org/springframework/amqp/rabbit/core/FixedReplyQueueDeadLetterTests.java

Answer 2

На самом деле, мне просто нужно указать ключ маршрутизации (так как это прямой обмен, а не разветвление). Я узнал, что из этого вопроса:

RabbitMQ dead letter exchange never getting messages