我有一个似乎是正确配置的 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;
}
RabbitMQ 控制台中显示的“some.queue”的绑定:
Parameters : x-dead-letter-exchange: dlx.queue