异常时未将RabbitMQ消息发送到死信队列

文章/答案/技术大牛

发布

1回答

spring-boot、spring-rabbit

@Value("${rabbitmq.main.messages.queue}") @Value("${rabbitmq.main.exchange.queue@Value("${spring.rabbitmq.host}") @Value("${spring.rabbitmq.portrabbitTemplate.

浏览 13提问于2020-10-09得票数 1

1回答

Spring Amqp + RabbitMQ中基于异常的不同死信队列

java、spring、rabbitmq、amqp、spring-amqp

给定一个使用RabbitMQ队列中的消息的基本MessageListener实现，如何根据处理消息时可能抛出的异常类型将消息发送到不同的死信队列？最初发布消息的队列上设置了x-dead-letter-exchange和x-dead-letter-routing-key，但在我的示例中这是不够的。

浏览 1提问于2014-04-07得票数 0

2回答

apache camel -向死信队列添加消息警报

java、apache-camel、rabbitmq、alerts

String queueA = "rabbitmq://host:5672/queue-a.exchange?) .processRef("dataProcessing") .end(); 消息来自当各种进程成功时，消息就会被消耗掉。如果失败，则将其添加到死信队列"deadLett

浏览 1提问于2016-02-18得票数 0

回答已采纳

1回答

春云流不抛异常

rabbitmq、spring-cloud、spring-cloud-stream

我正在使用春云流与rabbitMQ。我试图通过删除运行时的队列并将消息发送到已删除的队列来进行负面测试。source.queue2Source().send(MessageBuilder.withPayload(queue4DTO).build()); 我正在监听队列1中的消息，并将消息发送到队列2(已删除的消息我原以为上面的代码会抛出一个异常，但事实并非如此。甚至从队列<

浏览 0提问于2018-07-05得票数 0

2回答

在特定条件下，是否有任何方法从AWS函数中显式地向死信队列发送事件消息？

amazon-web-services、amazon-s3、aws-lambda、dead-letter

我试图通过调用AWS函数将s3event消息发送到rabbitmq。我已经将SQS配置为我的死信队列(DLQ)。我知道，当lambda调用失败或超时或资源约束等情况发生时，该消息将发送给DLQ。我的问题是，我想在一定条件下从lambda函数内部向DLQ发送事件消息，比如如果rabbitmq关闭或其他我感兴趣的条件。有同样的可能性吗？我是应该抛出异常，还是有其他更好的方法向DLQ发送事件消息。我使用

浏览 0提问于2018-03-21得票数 6

回答已采纳

1回答

RabbitMQ死信处理保证

rabbitmq、spring-amqp、reliability、dead-letter

如果我使用发布者确认，我可以(合理地)确定发送到RabbitMQ服务器上的exchange的消息以及从RabbitMQ服务器接收确认的消息不会丢失，即使RabbitMQ服务器崩溃(例如断电)。但是，当消息在使用者手动拒绝后到达死信交换时会发生什么？(channel.basicReject，我使用Spring AMQP。)如果原始消息从使用者正在侦听的队列中退出队列，并且RabbitMQ</e

浏览 6提问于2019-06-25得票数 1

1回答

RabbitMQ，死信交换->不能路由消息到默认交换？

rabbitmq、amqp、dead-letter

使用RabbitMQ管理(v3)，我尝试创建一个队列，该队列将向默认交换发送死信消息，并在该队列上绑定一个路由键"MyErrorRoutingKey“。所以在管理界面上，我留下了“死信交换”的空白。我只是想知道在尝试创建队列时使用以下消息是否正常： 406 PRECONDITION_FAILED -无效的arg‘x-死-字母路由-密钥’队列'MyQueue‘在vhost &#x

浏览 16提问于2013-01-03得票数 7

1回答

弹簧反应流-意外关闭

spring、spring-cloud-stream、spring-rabbit、reactive-streams、spring-reactive

我们在RabbitMQ中使用Spring反应性流。当queueAp

浏览 5提问于2020-04-09得票数 0

1回答

如何使用Apache在RabbitMQ消息上设置自定义标头？

rabbitmq、apache-camel、dead-letter

我正试图在我的消息中添加自定义标题，所以每当出现异常并在死信队列中结束时，我就可以看到异常是什么。然而，我所有的尝试都失败了。使用.setHeader() }); .doSomeStuff()

浏览 1提问于2019-02-08得票数 6

2回答

检查DLQ消息中的客户端异常

activemq、apache-camel

现在，我正在使用一个JMS队列，该队列具有重新传递策略，即回滚五次以上的消息将被发送到死信队列。当一条消息被发送到ActiveMQ中的死信队列时，有没有办法查看是什么异常导致了消息回滚？是否有消息属性可以设置来指定导致消息失败的原因？

浏览 0提问于2011-11-21得票数 0

1回答

如何在DLQ中自定义报头消息异常

apache-kafka、spring-cloud-stream

我想在死信队列中自定义异常消息，或者使用自定义异常消息添加新的头参数。现在，我在死信队列消息的报头中获得了原始堆栈跟踪public void consumer(Message<Content> message) {

浏览 0提问于2019-04-29得票数 0

2回答

RabbitMQ -如何配置条件DLX？

c#、rabbitmq

我有一个活动队列，它将包含来自Publisher的所有消息。根据消息处理结果，我的使用者读取这些消息和Acks/Nacks。channel.BasicNack(deliveryTag: ea.DeliveryTag, multiple: false, requeue: true);我的问题是让我们说，如果我想把消息转移到DLX后，重新尝试了10次？我该怎么做呢？它是C#代码还是可以

浏览 4提问于2016-03-22得票数 1

2回答

RabbitMQ - Apache阅读消息--如何处理失败消息

java、rabbitmq、dead-letter

将用户signUp发布到消息队列的。Java应用程序从该队列中读取并导入它。希望下面的图表能说明这一点。我只使用Java方面的东西。json消息已经存在于队列中。路由(Java消费端).; signUpDao.save(signUp);} ，我的问题是，当处理器无法导入消息时比如说，有一个DAO异

浏览 8提问于2015-10-17得票数 6

回答已采纳

1回答

RabbitMQ:将过期消息移动到自己的dlq？

rabbitmq

我们正在向rabbitMQ发送amqp消息，并且正在设置message-ttl属性。如果消息过期，它们将被移动到定义的DLQ。是否可以将过期消息移动到单独的DLQ，这样它们就不会因为更严重的原因而干扰移动到DLQ的其他消息？

浏览 0提问于2020-02-28得票数 1

1回答

Python芹菜-如果队列不可用，请进行提拔

python、queue、timeout、celery

Time_limit对我没有任何好处，因为任务永远不会到达它的队列。在这种情况下，我如何定义超时？换句话说，如果在下一个X秒内没有可用的队列，我想引发一个错误。这有可能吗？

浏览 2提问于2020-05-11得票数 1

回答已采纳

1回答

RabbitMQ -不同的死信交换被拒绝的消息和最大长度

rabbitmq

我有一个具有max length参数集的队列，按照设置。对于这个队列，还定义了一个死信交换。可以定义多个死信交换吗？一个用于拒绝消息，一个用于清除消息。我不介意清除的信息被默默地丢弃，而不是转发到死信交换。这样，只有被拒绝的消息在死信交换中结束.这有可能吗？

浏览 1提问于2017-07-09得票数 0

2回答

如何在Azure函数中手动发送消息到服务总线死信队列？

azure、azure-functions、azure-servicebus-queues

如果消息被毒害，则Azure Service总线队列触发函数将执行将消息发送到死信队列的默认策略。但是，是否可以手动将消息发送到死信队列？有几次由于某种内部或业务异常而不希望Azure函数执行其默认策略，我们希望将附加信息绑定到消息，并手动将其发送到Azure服务总线死信队列。在以前使用BrokeredMessage对象的版本中

浏览 3提问于2019-09-19得票数 1

回答已采纳

1回答

如何指定兔子消息的附加信息(当它是死字母)

java、rabbitmq、spring-amqp、spring-rabbit、rabbitmq-exchange

我有一条兔子队列，上面有供消费的信息。我也有一个可能失败的听众。队列配置为一个死信交换(以及一个死信队列)。我想要的是看到一个异常信息中的消息，坐在死信队列中。以下是它目前的工作方式：消息被拒绝，并通过死信交换进入死信队列。当我查看兔子管理UI中的死字消息

浏览 3提问于2015-11-19得票数 5

回答已采纳

2回答

即使保存失败，也会确认WebFlux/Reactive Spring RabbitmMq消息

spring-rabbit

我最近开始使用spring webflux和Rabbitmq以及cassandra reactive存储库。我注意到的是，即使在cassandra中保存某些元素也无法成功保存该消息。我传播了在保存过程中抛出的异常，但即使消息是从队列中删除的。我想知道我应该怎么做才能让Rabbitmq知道这条消息应该被认为是失败的(我想拒绝消息以将其发送到死信队列) @RabbitListener(queues =

浏览 0提问于2018-05-28得票数 0

3回答

RabbitMQ中死字的死字消息

rabbitmq、dead-letter

以下是我们所拥有的：我想要的是:如果一个消费者不能处理来自EQn的消息，它会用requeue: false连接消息，然后到达DLEQn --也就是说，在

浏览 5提问于2015-02-20得票数 6

回答已采纳

点击加载更多