-
1 votesanswersviews
将消息放入JBoss中的DLQ的原因
假设我有一个带有DLQ的队列,没有重新传递 . (运行时)处理消息(在MDB中)期间的异常导致消息被发送到DLQ,因此我可以决定如何处理它 . 到现在为止还挺好 . 但我认为在很多情况下,知道为什么消息没有得到正确处理会更好,换句话说,MDB中的例外是什么? 我认为从技术角度来看,将异常(或至少其堆栈跟踪作为字符串)附加到发送到DLQ的消息应该相当容易 . 在JMS属性中 . 到目前为止,我无法... -
1 votesanswersviews
Camel与ActiveMQ的死信队列?
我正在使用Dead Letter Channel EIP,正如Camel docs for Dead Letter Channel所描述的那样 . 这是我的camel.xml(删除了 Headers ) <camelContext id="camel" xmlns="http://camel.apache.org/schema/spring">... -
2 votesanswersviews
我可以获取异常或将消息放入死信/毒药队列吗?
我正在使用Azure的服务总线和this tutorial中描述的带有死信(毒药)队列的Web作业SDK . 保持简单,我正在使用POCO队列消息 . 当消息处理功能失败足够多次时,消息将移动到死信队列 . 我有另一个webjob消耗死信队列通知团队出了什么问题 . 有没有办法获得消息被移入死信队列的异常/原因?例如,如果POCO消息序列化失败并因此被移动到死信队列,那么找到它的最佳方法是什么? ... -
6 votesanswersviews
RabbitMQ - Apache Camel Reading消息如何处理失败的消息
我有以下PHP应用程序 . 将用户signUp发布到消息队列 . Java应用程序从该队列中读取并导入它 . 希望下面的图表能够描述它 . 我只是在Java方面工作 . json消息已存在于队列中 . Route (Java Consuming Side). @Component public class SignUpRouting { errorHandler(deadLetterC... -
1 votesanswersviews
Webshpere MQ基于提款计数器将消息重定向到DLQ
当IBM的撤销计数器大于3时,IBM WebSphere MQ是否有可能将消息从队列重定向到死信队列(DLQ)? -
0 votesanswersviews
如何在重新传递策略后阻止消息在Activemq中转到Dead LetterQueue(DLQ)
private BrokerService createBroker() throws IOException, Exception { BrokerService broker = new BrokerService();KahaDBStore kaha=new KahaDBStore(); File file =new File(path); ... -
2 votesanswersviews
Kafka的死信队列(DLQ)与spring-kafka
使用spring-kafka 2.1.x在Spring Boot 2.0应用程序中实现 Dead letter queue (DLQ) 概念的最佳方法是将所有未能通过某些bean的 @KafkaListener 方法处理的消息发送到某个预定义的Kafka DLQ主题并且不丢失单个消息? 因此消耗的Kafka记录是: 已成功处理, 无法处理并被发送到DLQ主题, 无法处理,未发送到DLQ... -
0 votesanswersviews
使用特定于路由的DLQ配置Java / Camel / AMQ
这里是Java 8 / Camel 2.19.x / AMQ 5.15.x. 我有一个Java应用程序,它使用Camel消耗AMQ队列中的消息,处理这些消息,并对它们进行处理 . 有时,路由的输出将处理结果重新放回另一个队列以进行进一步的下游处理,但不总是/必然 . 典型的Java / Camel / AMQ设置 . 我的每个路由(我使用的是Camel XML DSL)都有一个配置好的 <o... -
0 votesanswersviews
如何忽略maxAttempts并向DLQ发送消息?
我正在使用RabbitMQ . 消费者-api正在使用spring-cloud-steam . 目前,当maxAttempts为3时,如果消费者未能处理该消息,则它将再次排队 . 这将发生3次 . 如果第3次也是消息失败,则它将被发送到DLX-> DLQ . 如下图所示 现在我想跳过重试,如果在侦听器端发生了一些specificException . 如何跳过此重试并直接将消息发送到DLX-... -
1 votesanswersviews
死信队列
我的问题是关于WebSphere MQ的死信 . 我如何在ISPF上查看队列管理器的死信? 每个队列管理器都有一个默认的死信队列,或者我需要定义它? 非常感谢! -
2 votesanswersviews
在WebSphere MQ中配置死信队列
我在我的应用程序中使用IBM Websphere和MQ,现在我想知道如何配置(或)使Websphere了解在MQ中创建了一个死信队列说DEAD.QUEUE并且它应该使用此队列处理来自请求/响应队列的消息时失败 . 我试图这样做是因为队列中有一条失败的消息,它试图一次又一次地将它重新发布到队列中 . 如果配置了死信队列,那么我猜这可能会停止 . 如果我错了,请纠正我 . -
2 votesanswersviews
Spring RabbitMQ指数退避与RetryTemplate无响应
我正在开发一个Spring项目,我正在尝试使用RabbitMQ队列的死字法实现指数退避 .在此过程中,我创建了一个名为RetryTemplate的ExponentialBackOffPolicy .出于测试目的,我的消费者只是通过抛出异常来拒绝它获得的所有消息 . 这是我的RabbitMQConfiguration类的样子: @Configuration @EnableAutoConfigurat... -
8 votesanswersviews
如何在Azure Service Bus主题上删除DeadLetter消息
我正在写一段代码,这将允许我们: 查看Azure Service Bus主题(Peek)中存在的所有死信消息的列表 修复并将其发回主题 重新发送时从死信队列中删除它们 . 前2分我没有问题;使用Peek接收模式,我可以显示消息列表,我们可以编辑和重新发送,没有任何问题 . 当我想从死信队列中删除消息时,问题就来了 . 我们如何通过消息级别对消息执行此操作?我们可能只想删除驻留在死信... -
2 votesanswersviews
我们如何分析Activemq的Dead Letter队列中的消息
然后,代理接收消息并将其发送到死信队列,以便稍后进行分析 . 这些是来自apache activemq文章的引用 . 我的策略也一样 . 我想稍后分析死信队列中的消息 . 我怎样才能做到这一点? -
1 votesanswersviews
有没有办法在某种条件下从AWS lambda函数内部显式发送事件消息到死信队列?
我正在尝试通过调用AWS lambda函数将s3event消息发送到rabbitmq . 我已将SQS配置为我的死信队列(DLQ) . 我知道当调用lambda失败或者超时或资源限制等情况时,消息会被发送到DLQ . 我的问题是,我想在某些条件下从lambda函数内部向DLQ发送事件消息,例如,如果rabbitmq已经关闭或者我感兴趣的其他条件 . 有没有相同的可能性?我应该抛出异常还是有其他更好... -
1 votesanswersviews
如何在Camel死信路线中同时拥有原始信息和重新传递计数器
我有一个配置了死信通道的Camel路由,如下所示: from(...) .errorHandler(deadLetterChannel("vm:deadLetter") .useOriginalMessage() .retryWhile(method(new BadMessageRuleset(redeliveryTimes), "shouldRe... -
39 votesanswersviews
RabbitMQ死信交换永远不会得到消息
我正在尝试设置我的第一个RabbitMQ死信交换,这是我通过Web管理界面使用的步骤: 使用名称"dead.letter.test"创建新的DIRECT交换 创建新队列"dead.letter.queue" 绑定"dead.letter.queue"至"dead.letter.test" 创建新队列&q... -
1 votesanswersviews
RabbitMQ死信交换/队列
我不太了解死信交换/队列 . 在线文件说: republished to another exchange when any of the following events occur: The message is rejected (basic.reject or basic.nack) with requeue=false, The TTL for the message e... -
6 votesanswersviews
ActiveMQ:死信队列保持我的消息顺序
我使用ActiveMQ作为代理来传递消息 . 这些消息是用dabatase写的 . 有时,数据库无法访问或关闭 . 在这种情况下,我想回滚我的消息,以便稍后重试此消息,我想继续阅读其他消息 . 这段代码工作正常,除了一点:回滚消息阻止我阅读其他代码: private Connection getConnection() throws JMSException { RedeliveryPol... -
0 votesanswersviews
如何在%DLQ%中处理邮件
我正在尝试使用%DLQ%中的消息,但失败了 . 它 08:33:30.588 [RebalanceService] ERROR RocketmqClient - AllocateMessageQueueStrategy.allocate Exception. allocateMessageQueueStrategyName=AVG java.lang.IllegalArgumentExceptio...