Spring AMQP - nothing showing up in dead letter queue

Question

I have what seems to be a correctly configured RabbitMQ queue (shows the dlx argument) and in my Java listener code, I throw a FatalListenerExecutionException. For some reason, nothing is showing up in the designated dead letter queue after the exception is thrown.

Am I throwing the wrong kind of exception?

Thanks.

Queue instantiation in Spring configuration:

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

Listener Container in Spring configuration:

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;
    }

Bindings for "some.queue" shown in RabbitMQ console:

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

Artem Bilan · Answer 1 · 2015-02-03T15:18:17.710

1

You must throw AmqpRejectAndDontRequeueException or there is just enough to setup defaultRequeuRejected="false" for the listener container.

See the test-case from Spring AMQP: https://github.com/spring-projects/spring-amqp/blob/master/spring-rabbit/src/test/java/org/springframework/amqp/rabbit/core/FixedReplyQueueDeadLetterTests.java

edited Feb 03 '15 at 15:18

answered Feb 02 '15 at 21:26

Artem Bilan

113,505
11
91
118

Thanks. I actually have defaultRequeuRejected="false". – mstrom Feb 02 '15 at 21:52
You need to show your configuration including the DLX/DLQ binding. – Gary Russell Feb 02 '15 at 22:40
Thanks. I added detail to the original question. – mstrom Feb 03 '15 at 15:12
Added a link to the test-case on the matter and based on the Java Config. You should be sure that you have an Excahnge for Dead letter and some binded queue to receive those dead messages. – Artem Bilan Feb 03 '15 at 15:19

score 0 · Answer 2 · edited May 23 '17 at 12:09

0

Actually, I just needed to specify the routing key (since it's a direct exchange and not a fanout). I learned that from this question:

RabbitMQ dead letter exchange never getting messages

edited May 23 '17 at 12:09

Community

1
1

answered Feb 03 '15 at 18:39

mstrom

1,655
3
26
41

Spring AMQP - nothing showing up in dead letter queue

2 Answers2