我正在使用AWS SQS和死信队列。
这可能吗?我是不是缺少了一个配置选项?
问候你,伊多
死信队列不是为此目的设计的;它们专门处理可以成功接收消息,但无法成功处理的情况(源)。所以简而言之,这是目前不可能的。或者,您可以增加消息保留时间,使消息在队列中停留的时间更长,从而使用户有机会重新开始监听。
希望能有所帮助:)
我需要将我的消息发送到死信队列从Azure主题订阅在任何错误的情况下,而阅读和处理从主题的消息。所以我尝试直接将消息推送到DLQ。 我的样本代码会像 我试着获取死信队列路径 我得到了死信队列的路径,如=“mytopic/$deadletterqueue” 但它在将路径作为主题名传递时不起作用。它引发实体主题未找到异常。 有谁能告诉我这件事吗 参考:如何使用Java将错误消息移动到Azure死信队列
我已经设置了Apache camel,在其中我使用来自一个队列的消息并对其进行某种操作,然后将其传输到其他队列。 现在,如果异常来了,我希望它应该回滚,然后在6次尝试后,它发送到死信队列,目前回滚发生5-6次,但我的消息没有转移到死信队列。 这里会发生什么-->Queue1->>(消耗)-->Operation(引发异常)-->Rollback-->Queue1->>(消耗)-->Operatio
我有一个使用RabbitMQ构建的发布-订阅场景。有一个交换,其中消息由发布者发送,订阅该交换的任何使用者在其各自的队列中接收这些消息。这是一个扇出场景,其中有一个生产者,但有多个消费者。 现在我愿意在系统中集成一个死信队列,以便稍后处理被拒绝的消息。我的问题是 1)我应该为每个使用者配置一个单独的死信队列,还是应该有一个单独的死信队列来处理来自所有使用者的所有被拒绝的消息? 2)如果两者都有可能
如果消息中毒,Azure服务总线队列触发函数将执行默认策略,将消息发送到死信队列。但是,我们是否可以手动将消息发送到死信队列?有几次,由于某种内部或业务异常,我们不希望Azure Function执行其默认策略,我们希望将其他信息绑定到消息,并手动将其发送到Azure服务总线截止日期队列。 在以前使用BrokeredMessage对象的版本中,有一个名为 然而,在最新的Functino 2中。十、
这种需求类似于通过公开的REST服务API(Spring Boot)处理来自死信队列的消息。以便一旦调用REST服务,就会从DL队列中消耗一条消息,并将再次发布到主队列中进行处理。@RabbitListener(queues=“queue_name”)立即使用消息,这在场景中是不需要的。该消息只需由REST服务API使用。有什么建议或解决办法吗?
Artemis 2.2.0的新版本有一个,它显然是在内部消息ID(而不是JMS消息ID)上操作的。 问题是:如何在Artemis Version2.x中使用JMS消息ID将消息从一个队列移动到另一个队列?