问题标签 [dead-letter]

For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.

0 投票
4 回答
13512 浏览

azure - 如何查看死信消息

很难找到一些好的文档来获取死信队列中的所有消息并查看它们。

我有一个 Azure 服务总线队列,我能找到的所有内容都是针对 Azure 服务总线主题的。

有人可以帮助我快速指南吗?

0 投票
2 回答
313 浏览

ibm-mq - Webshpere MQ 基于提款计数器将消息重定向到 DLQ

IBM WebSphere MQ 是否有可能将消息从队列重定向到死信队列 (DLQ),当它的撤回计数器大于 3 时?

0 投票
1 回答
685 浏览

error-handling - 在 Apache Camel 中重新交付用尽后如何调用 Web 服务?

我没有找到促进解决此问题的企业集成模式或方法:

在重新发送尝试用尽后,我需要将 Web 服务请求发送回原始源,以通知发送者发送失败。

在用尽所有重新传递尝试后,我应该将消息移动到死信队列吗?然后创建一个新的消费者来监听那个 DL 队列?我的每个源消息队列都需要一个唯一的死信队列吗?我是否应该在将消息头移到死信队列之前添加消息头,注意源队列?如果所有消息都进入一个死信队列,我的消费者应该如何知道将 Web 服务请求发送到哪里?

你能指点我一本书、博客文章或文章吗?规定的方法是什么?

我正在使用一个非常旧版本的 Fuse ESB,但我希望 ServiceMix 中的解决方案同样适用。

或者,我要求的是反模式或代码气味。请指教。

0 投票
1 回答
312 浏览

rabbitmq - 过期队列上的死信消息与一致的哈希交换绑定

我有一种情况,我正在处理与特定来源相关的事件。每个源都有一个键或 ID,我可以将其用作散列。来自每个源的事件必须按顺序处理,但来自不同源的事件可以并行化,以实现水平可伸缩性。将有数百个源密钥。

我计划在向 RabbitMQ 提交消息时将密钥设置为路由密钥的一部分,然后使用consistent-hash-exchange以便将来自同一源的事件路由到同一队列。然后我正在考虑使用 TTL 动态绑定来自消费者的私有队列(以便在消费者关闭时优雅地删除它们)。一开始我只会有 2 或 3 个消费者来实现冗余,但如果我想因消息数量增加而扩大规模,我可以启动另一个消费者。

我的问题是如果消费者宕机并且队列中有消息会发生什么?理想情况下,我希望将队列中的消息重新路由回交换器,并将consistent-hash-exchange它们路由到不同的队列(因为原始队列将不再存在)。

RabbitMQ 关于死信的文档没有明确提到消费者队列上的 TTL 场景,或者当队列被删除时会发生什么。

我的方法有意义吗?如何在通过特定路由键保留排序的同时实现我正在寻找的消费者容错?

注意:我知道如果在将死信消息路由到交换器的过程中,会出现更微妙的竞争条件,新消息最初路由到过期队列,现在将路由到不同的消费者,因此排序将是在那个特定的情况下被打破。

0 投票
1 回答
1428 浏览

c# - How to retrieve Dead Letter Queue count?

Question

How do i get the dead letter queue length without receiving each message and counting how many message I received?

My Current Implementation

Problem with implementation

Because I am receiving each message in peek and block mode, the messages have a lock duration set. During this time i cannot receive or even see the messages again until this time period has timed out.

There must be an easier way of just getting the count without having to poll the queue?

I do not want to consume the messages either, i would just like the count of the total amount.

0 投票
2 回答
4873 浏览

spring-boot - ActiveMQ 重新传递不起作用

我正在尝试使用 ActiveMQ 实现死信队列。不幸的是,这方面的文档在某些方面相当模糊,我似乎无法正确设置所有内容。

我配置了以下 Bean:

这是我的接收代码:

然而,什么也没有发生。我正在使用默认配置的开箱即用 Apache ActiveMQ 5.14.2 设置。我在这里想念什么?

0 投票
0 回答
31 浏览

java - AKKA 消息传递失败

我的演员系统中有以下层次结构

大师级演员

奴隶演员

Master Actor 是根据请求创建的,对于第一个请求,此层次结构正常工作,对于第二个请求,“differentMessage仍未交付”

请注意,这两个参与者之间有很多消息交换。但我没有添加它们,因为它们没有什么不同。消息的数量会成为问题吗?

男主角死的依据是什么?太多的上下文切换网络参与者会导致这种情况吗?

0 投票
2 回答
1023 浏览

azure - 将过期的死信消息重新提交回队列

我在天蓝色服务总线死信队列中有大量消息。当我看到这些消息时,我看到大部分消息都已过期。

我想知道当我们尝试将过期的死信队列消息重新提交回其原始队列时会发生什么?

谁能帮我解释一下?

谢谢 !

0 投票
1 回答
754 浏览

architecture - 如何避免消息落入死信队列?

如何设计一个应用程序,使消息尽可能避免死信队列。

根据下面的维基百科文档,消息被发送到死信队列的原因

  • 发送到不存在的队列的消息。
  • 超出队列长度限制。
  • 超出消息长度限制。
  • 消息被另一个队列交换拒绝。
  • 消息达到阈值读取计数器数,因为它没有被消费。有时这被称为“退出队列”。

我们将能够设计系统避免已知的原因。但是如何让系统解决未知的场景。我不是在寻找任何供应商特定的解决方案,而是一般的设计指南或建议。

0 投票
0 回答
343 浏览

scala - 为什么在尝试使用断点调试 akka actor 时会收到死信?

我在这里设置了一个断点:

我得到了:

  • 为什么会这样?

  • 为什么我会收到死信?

  • 是因为消息超时吗?

  • 如果是,有没有办法将超时间隔设置为无限?

  • 如果原因是其他原因,那么有没有办法确保由于使用断点进行调试而不会出现死信?