RabbitMQ死信交换从未收到消息

吉尔登

我正在尝试设置我的第一个RabbitMQ死信交换,这是我通过网络管理界面使用的步骤:

  1. 创建新的直接交换,名称为“ dead.letter.test”
  2. 创建新队列“ dead.letter.queue”
  3. 将“ dead.letter.queue”绑定到“ dead.letter.test”
  4. 创建将死信交换设置为“ dead.letter.test”的新队列“ test1”
  5. 发送消息到“ test1”
  6. 否定(带有requeue = false)“ test1”中的消息

我希望这些步骤应该通过“ dead.letter.test”交换记录到“ dead.letter.queue”中。这没有发生。

我可以手动将消息放入“ dead.letter.test”交换中,并显示在“ dead.letter.queue”中,所以我知道这很好。

当我查看管理UI时,它表明在队列“ test1”上设置了DLX参数。

我要去哪里错了?

吉尔登

Gentilissimo Signore非常友善地在Twitter上回答了我的问题。问题是,如果将死信交换设置为DIRECT,则必须指定死信路由键。如果您只是想让所有被NACKed的消息都进入一个死信存储区以供以后调查(就像我一样),则应该将死信交换设置为FANOUT。

这是有效的更新步骤:

  1. 创建新的FANOUT交换,名称为“ dead.letter.test”
  2. 创建新队列“ dead.letter.queue”
  3. 将“ dead.letter.queue”绑定到“ dead.letter.test”
  4. 创建将死信交换设置为“ dead.letter.test”的新队列“ test1”
  5. 发送消息到“ test1”
  6. 否定(带有requeue = false)“ test1”中的消息

本文收集自互联网,转载请注明来源。

如有侵权,请联系[email protected] 删除。

编辑于
0

我来说两句

0条评论
登录后参与评论

相关文章

来自分类Dev

RabbitMQ死信交换从未收到消息

来自分类Dev

RabbitMQ中的死信死信消息

来自分类Dev

RabbitMQ使用者未收到该消息

来自分类Dev

我的表格从未收到过发布的自定义消息

来自分类Dev

Kafka Java使用者从未收到任何消息

来自分类Dev

我的表单从未收到过发布的自定义消息

来自分类Dev

可打包的自定义处理程序,消息从未收到

来自分类Dev

RabbitMQ是否需要单独进行死信交换?

来自分类Dev

Kotlin-从未收到MutableStateFlow Emmision

来自分类Dev

从未收到 AutoResponded 事件通知

来自分类Dev

子进程未收到消息

来自分类Dev

ExchangeTimedOutException:未收到OUT消息

来自分类Dev

Scala演员:未收到消息

来自分类Dev

设备未收到GCM消息

来自分类Dev

SailsJS,SocketIO,未收到消息

来自分类Dev

内容脚本未收到消息

来自分类Dev

Django通道未收到消息

来自分类Dev

星号未收到rtp消息

来自分类Dev

Firefox未收到EventSource消息

来自分类Dev

Elixir进程未收到消息

来自分类Dev

RabbitMQ消费者未收到生产者发送的消息

来自分类Dev

Firebase 消息传递,未收到消息

来自分类Dev

无法收到消息RabbitMQ

来自分类Dev

Android:从未收到广播ACTION_MY_PACKAGE_REPLACED

来自分类Dev

发送从未收到的多播数据包

来自分类Dev

iOS 使用cordova 推送通知。从未收到通知

来自分类Dev

Akka父母未收到孩子的消息

来自分类Dev

Pushwoosh / GCM-Android-未收到消息

来自分类Dev

设备未收到来自GCM的消息