回答情况：
提问时间：
问题标签：
我的问题是：RabbitMQ Dead Letter Attributes ->我这里的问题是，即使手册说默认的交换绑定到每个队列，它也不会根据路由标准转发它。这也会发生在死信交换的amq.direct中，包括目标队列上的绑定。
为我打开空白:如果接收者必须是死信队列<
浏览 27提问于2018-01-22得票数 1
我面临着这样一种场景:队列中的每条消息都应该在延迟一段时间后被消费，这可以使用RabbitMQ中的TTL和死信交换来实现，但当最大TTL将位于头部时，其他消息将不会被消费。我希望实现队列中的每个消息在延迟后被消费，而不管它在队列中的位置。
浏览 18修改于2020-06-02得票数 0
我正试图在Go中写一个RabbitMQ消费者。它一次从队列中取出5个对象并对它们进行处理。此外，如果成功地处理了否则发送到死信队列5次，然后丢弃，那么它应该被无限地运行，并处理使用者的取消事件。Model在RabbitMQ中是什么，在RabbitMq中是什么？如何在死信队列失败时发送对象，并在ttl后再次对其进行重新队列
在下面的代码中，consumerTag参数在ch.Consume函数中的意义是什么？To exit press
浏览 1修改于2016-04-07得票数 4
回答已采纳
我用队列设置了一个死信路由，以请求延迟数秒的被拒绝消息，防止临时使用者错误阻塞队列。我已经将其设置为工作队列和死信队列都绑定到相同的交换：
外部产生的传入消息被路由到exchange，后者将它们放置在工作队列中。我们没有拒绝消息并将其再次置于队列的首位(导致无限循环)，而是将被拒绝的消息(使用requeue=0)路由到交换中，将死信队列添加为路由密钥。如果使用者失败，消息将被拒绝(与re
浏览 0提问于2020-10-03得票数 4
回答已采纳
但是，按照我设置的方式，消息不会延迟，它会立即返回队列。我想等10秒才向main_queue发送消息。connection.start
channel = connection.create_channel
浏览 8提问于2022-09-15得票数 0
如果我使用发布者确认，我可以(合理地)确定发送到RabbitMQ服务器上的exchange的消息以及从RabbitMQ服务器接收确认的消息不会丢失，即使RabbitMQ服务器崩溃(例如断电)。但是，当消息在使用者手动拒绝后到达死信交换时会发生什么？(channel.basicReject，我使用Spring AMQP。)如果原始消息从使用者正在侦听的队列中退出队列，并且RabbitMQ服务器随后崩溃，我是否仍然可以确定，在RabbitMQ服务器重新启动
浏览 6修改于2019-06-26得票数 1
我计划通过遵循这两个链接 来延迟队列中消息的处理。所以，正如链接中所建议的。我已经用x-dead-letter-exchange和x-dead-letter-routing-key args声明了原始队列。它将消息发布到所谓的dead-letter-queue中，当消息被使用者处理失败或发生ttl或队列长度超过时。现在，在dead-letter-queue中，类似的args与ttl参数一起被设置。它应该在ttl超出后将消息重新发布到原始队列。但问题是它放弃了所有的信息。
此外，这里有一个陷阱。如果我显式地
浏览 4提问于2016-04-08得票数 1
回答已采纳
那么，可以做活队列=>死信队列=>活动队列吗？我能够做到:实时队列=>死信队列和死信队列=>实时队列.
浏览 5修改于2017-05-23得票数 1
回答已采纳
可以将消息发布到带有过期TTL的RabbitMQ队列中:这样的消息将在TTL完成后过期，并且(如果设置了死信队列，则)移到死信队列中。蒂娅。
浏览 0提问于2014-11-18得票数 7
回答已采纳
我在码头图像中有RabbitMQ集群。RabbitMQ有一个交换"EventExchange“和两个队列："QueueWait”和"QueueAction“。配置用于重发的队列：
消息插入到具有可变过期时间的队列QueueWait中。但是，如果在默认情况下从QueueWait
浏览 1修改于2014-10-21得票数 0
回答已采纳
使用RabbitMQ管理(v3)，我尝试创建一个队列，该队列将向默认交换发送死信消息，并在该队列上绑定一个路由键"MyErrorRoutingKey“。所以在管理界面上，我留下了“死信交换”的空白。我只是想知道在尝试创建队列时使用以下消息是否正常：
406 PRECONDITION_FAILED -无效的arg‘x-死-字母路由-密钥’队列'MyQueue‘在vhost '/'：routing_key
浏览 16提问于2013-01-03得票数 7
使用Spring (使用RabbitMQ作为message )，我正在准备一条消息，有时我希望使用我的消息。在此之前，它可以在一些队列(如等待队列)中等待，然后移动到我们的主队列中，在那里有消费者正在等待处理来自主队列的消息。我搞不懂是否应该在这个场景中应用死信交换，以及如何在其中应用死信交换，这对我来说是的一个大问题，。
知道我们怎么能让它运转起来吗。如果没有rabbitmq_delayed_message_exchange插件是可能的话。
浏览 3修改于2016-12-22得票数 0
如果发生死信交换，是否有自动删除队列的选项？例：
它正确地将消息路由到员工。现在如何告诉RabbitMQ在使用辅助队列后删除它们？或者我必须手动删除它们(例如，使用另一个“垃圾收集器”队列)？
浏览 2提问于2013-12-04得票数 0
回答已采纳
2回答
在将消息放入死信队列后，如何在RabbitMQ中手动重试？
RabbitMQ是否提供了用户界面，您可以通过该界面执行此操作？在这里，我假设RabbitMQ控制台不为您提供此功能。
浏览 0提问于2015-12-16得票数 2
1回答
我有一个由SQS队列触发的lambda函数。当lambda无法处理消息时，它会将消息重新驱动到死信队列。死信队列配置了5分钟的传递延迟，但任何消息都是可见的，并立即进行处理。 交付延迟似乎被忽略了。有没有办法为SQS配置“重新驱动延迟”？
浏览 9提问于2019-02-27得票数 3
回答已采纳
我需要安排延迟消息，所以我声明了一个带有x死信交换和x死信路由密钥的延迟队列DELAY_STAT，它将路由到默认的交换到我的目标队列统计数据。当我需要为队列STAT安排延迟消息时，我会在到期时将消息发布到DELAY_STAT，当到达消息ttl时，它将是一个死信，然后路由到STAT，以便可以使用它。这意味着如果B更早地发送，一些短延迟消息A将被长延迟消息B所堆积。
浏览 1修改于2018-06-22得票数 0
我有一个最初声明如下的RabbitMQ队列：我正在尝试添加一个死信交换var result = _channel.QueueDeclare("NewQueue", true, false, false, args);
引发的异常：'RabbitMQ.Client.Exceptions.
浏览 1提问于2016-10-20得票数 4
回答已采纳
我使用aws sdk将lambda中失败的消息发送到死信队列。我希望在将消息发送回主队列进行重新处理之前等待几个小时。我有一个lambda连接到我的死信队列。我可以使用delay将消息发送到死信队列。但最大延迟是15分钟。但是我想等更多的时间。以前有人这么做过吗？
浏览 3修改于2019-10-18得票数 1
我正在尝试将Apache QPID Broker (版本7.1.6)作为内存代理中的嵌入式运行，并在代理上声明一个队列，同时将队列声明选项x-qpid-dlq-enabled设置为"true“。6.1.0/java-broker/book/Java-Broker-Runtime-Handling-Undeliverable-Messages.html 预期的行为是，如果使用该选项，则会自动创建死信交换和死信队列从上面的第二个链接开始： “DLQ功能导致生成死
浏览 17提问于2019-12-19得票数 0
我正试图在我的消息中添加自定义标题，所以每当出现异常并在死信队列中结束时，我就可以看到异常是什么。然而，我所有的尝试都失败了。TEST","TEST"); .doSomeStuff() }}rabbitmq://foo
?deadLet
浏览 1提问于2019-02-08得票数 6
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号