Spring AMQP-死信队列中没有显示任何内容
我似乎有一个正确配置的RabbitMQ队列（显示dlx参数），在Java侦听器代码中，我抛出了一个FatalListenerExecutionException。由于某种原因，在引发异常后，指定的死信队列中没有显示任何内容。
我是不是抛出了错误的异常？
谢了。
Map arguments = new HashMap();
arguments.put("x-dead-letter-exchange", "dlx.queue");
new Queue("some.queue", true, false, false, arguments);
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;
}
Parameters : x-dead-letter-exchange: dlx.queue
共有1个答案
您必须抛出AMQPrejectandDontRequeueException，或者只有足够的资源为侦听器容器设置DefaultRequeRejected=“false”。
请参见Spring AMQP中的测试用例：https://github.com/spring-projects/spring-amqp/blob/master/spring-rabbit/src/test/java/org/springframework/amqp/rabbit/core/fixedReplyQueueDeadletterTests.java
-
死信队列（Dead Letter Queue）本质上同普通的Queue没有区别，只是它的产生是为了隔离和分析其他Queue（源Queue）未成功处理的消息。 创建死信队列的方法参见createQueue() API，与创建普通队列无异， 死信队列不可调用deadMessage(), deadMessageBatch API，其他操作都与对普通Queue的操作无异。 为了将源Queue的未能成功处理
-
对于异步的触发器，平台会对函数失败的任务进行最多3次重试。 在新建触发器的时候，为触发器配置一条死信队列，从用户的EMQ队列中选择一条,用于接收函数失败的任务。 在设置死信队列前，请对group: CIf76b0600-24e9-42c4-acf3-d491fbd9fd71 授予 FULL_CONTROL 权限，若不授予权限，平台将丢弃失败的任务信息。 消息的内容如下,以后可能增加字段，请用户在
-
我有一个lambda函数，我想为它创建一个SQS死信队列。我首先在Terraform中创建SQS： 这是来自Terraform的例子。但是，我被redrive_policy卡住了。 我是否正确理解，这为SQS队列设置了一个死信队列？ 如果我设置了redrive_policy，这意味着我在一个DLQ上设置了一个DLQ。我觉得可以在DLQ上设置DLQ，在DLQ上设置DLQ，以此类推。 我找不到这方面的
-
未创建我的exchange和dlq。我在下面的YML中有以下内容。我确实创建了一个匿名队列，但也没有发布消息。任何想法。
-
什么是最好的方法来实现死信队列（DLQ）的概念在Spring Boot 2.0应用程序中使用sping-kafka 2.1. x有所有的消息被处理失败的@KafkaListener方法的一些bean发送到一些预定义的Kafka DLQ主题并且不丢失一条信息？ 因此，Kafka的记录是： 已成功处理， 处理失败，并发送到DLQ主题， 处理失败，未发送到DLQ主题（由于意外问题），因此将再次被侦听器使
-
我试图手动控制级联剑道下拉列表。我将一个“级联”事件绑定到父级，触发后，转到我的服务器获取与父级dropdownlist值关联的子dropdownlist值，并尝试更新子数据源：
-
我正在尝试使用Lambda的一纸空文队列。我已将其配置为将消息发送到SNS队列。我放入了一个不正确的处理程序，以使Lambda调用错误消失。错误消息永远不会到达SNS队列。我相信这是一个权限问题。下面是SNS队列的“我的访问策略”设置 lambda函数附加了一个角色，该角色具有、到以及到 我错过什么了吗？有没有其他原因消息可能不会到达DLQ？
-
我正在尝试设计一个基于SQS、Lambda和SNS的小型消息处理系统。在失败的情况下，我希望将消息排入死信队列(DLQ)中，并调用webhook。 目前，如果一切顺利，流程应该是这样的： SQS（用于处理重试）将消息排入队列 lambda由SQS调用并处理消息 lambda发送webhook，并正常完成 如果lambda中的某些东西出错（无法调用success webhook，无法处理手头的任务）