gpt4 book ai didi

java - 访问ActiveMQ的死信队列中的消息并在消费后重新发送到webservice或socket

转载 作者:行者123 更新时间:2023-12-01 16:51:08 24 4
gpt4 key购买 nike

我使用ActiveMQ用Java编写一个应用程序,其中使用生产者和异步消费者机制,生产者发送的消息由于网络故障而不会被消费。因此这些消息被发送到ActiveMQ的死信队列。

我的问题是如何访问死信队列中的消息并通过在消费者中使用它并发送到网络服务或套接字等来执行重试。任何代码示例都很棒。

最佳答案

DLQ 就像任何主题或队列一样,您可以像任何主题或队列一样订阅它并消费累积的消息。这是列表http://activemq.apache.org/advisory-message.html

如果您没有individualDeadLetterStrategy,则要订阅的DLQ 的名称为ActiveMQ.DLQ,您可以订阅onMessage 方法并执行您的操作。 http://activemq.apache.org/message-redelivery-and-dlq-handling.html

关于java - 访问ActiveMQ的死信队列中的消息并在消费后重新发送到webservice或socket,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/39956232/

24 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com