我正在使用具有请求/响应模式的Masstransit，我想指定死信消息队列名称和与此队列相关的其他配置(如果可用)，我看到类型IPipeConfigurator有一个UseDeadLetterQueue扩展方法，但在ReceiveEndpoint方法中我必须配置的类型是IRabbitMqReceiveEndpointConfigurator，所以我不知道如何指定死信消息队列，可能我试图<e
浏览 6提问于2016-12-30得票数 0
回答已采纳
目前，我所处的情况是，事件需要更新DB中的一定数量的记录。通常，这不会超过几秒钟，但在某些情况下，可能需要超过1分钟。在此场景中，使用者在30秒后接收相同的消息并重试。
浏览 5提问于2021-12-07得票数 0
回答已采纳
我试图在一段时间后没有收到消息时通知用户，使用MassTransit和RabbitMQ。如何从死信队列中检索消息？在下面的尝试中，该消息会立即
浏览 0提问于2019-03-27得票数 1
回答已采纳
我需要处理死信队列中的消息。我如何为这个创建处理程序？另外，我还需要处理来自错误队列的消息，这些消息也是死信的。
浏览 0提问于2017-03-29得票数 0
回答已采纳
目前，我正尝试从aws迁移到MassTransit。我在连接到SQS/SNS方面有一个很大的问题。我们的基础设施团队使用terraform脚本创建了sqs/sns。我们使用的是MassTransit 8.0 (最新版本)名称：bci-name-dev-aim-name在我们订阅SNS的地方：作为一个主题
名称：bci-name-dev-ai
浏览 8提问于2022-07-07得票数 0
回答已采纳
我已经开始更多地使用masstransit的消息数据功能，并且正在达到需要管理存储中的消息数据的地步-即删除旧数据。显而易见的选择是让一些外部进程整理数据，但很明显，计划的(或不计划的)清理可以删除仍在使用的数据，或者被错误或死信队列引用的数据。理想情况下，我希望将存储的消息数据保留限制为只保留错误或死信队列中的消息，并自动删除已成功处理的消息的数据。
使用MassTran
浏览 0提问于2020-08-21得票数 0
2回答
我正在使用NServiceBus浏览几个示例，我偶然发现了一个特性，我希望它附带MassTransit (因为它是免费服务)。
该功能基于‘中毒’消息。如果由于系统中的错误，这些消息永远无法处理，并永久地出现在错误队列中。'redirected‘NServiceBus有一个很酷的特性，一旦您纠正了代码中的错误，就允许错误队列中的这些消息成为redelivered.。这是通过使用特定于ReturnToSour
浏览 1提问于2015-07-30得票数 1
回答已采纳
我目前正在进行一个项目，我们希望使用一个死信队列来重新传递消息，而不是使用MassTransit的内置调度程序。这个想法很简单:如果消费者抛出一组特定的异常，我们会多次重试该消息，然后重新调度消息，以便在不久的将来重新发送。例如，如果消息以错误的顺序到达。我正在尝试完成本文中的选项2( )
每当我的使用者抛出异常时，MassTransit就会将消息移动到_error队列，而不是死信。我确信这是我的
浏览 5提问于2020-07-15得票数 1
我在Azure函数中运行MassTransit 7.1.8，使用服务总线作为传输。~fault上手动创建订阅，以便开始接收那里的消息。我的问题：
MyFunction正在吞咽异常，以防止消息被发送到DLQ。这样可以吗？吞下一个异常感觉很奇怪，但另一方面，MassTransit将错误发送到错误队列，因此它不会丢失。文档讨论了创建_error队列(前缀适当)的问题，但我没有看到任何这样的队列或主题，只有masstransit</e
浏览 17提问于2021-05-21得票数 0
回答已采纳
我正在尝试找到一个代码，使用MassTransit从Azure死信队列中读取消息，并在控制台中打印它。寻找正确的类和方法来完成这项工作。
浏览 4提问于2021-09-21得票数 1
我花了几天时间测试MassTransit 3.1.2，看看我们能否在应用程序中使用Azure Service Bus。当我启动应用程序时，实体(队列、主题、订阅)将在Azure上的我的命名空间上自动创建。由于这个
浏览 6提问于2016-01-30得票数 8
回答已采纳
这两个应用程序在RabbitMQ上使用相同的主机。
appA使用bus.Send方法将命令CreateEntityCommand发送到appB，进入bQueue。在appB中，我有一个消费CreateEntityCommand的消费者。我的appA中的EntityCreatedEvent使用者做得很对，但是事件也被添加到bQueue_skipped中，为什么呢？在bQueue中生成故障。我希望我的appA使用故障，但故障自动显示在bQueue上。如果我将appA
浏览 39提问于2018-10-12得票数 -1
回答已采纳
我使用的是Masstransit请求/响应模式。所以我有一个请求者应用程序和一个消费者应用程序，它们工作得很好。我没有配置任何重试/重发，就好像消费者中发生了任何错误一样，请求者将处理它，或者可能正在发送另一个请求。到目前一切尚好。但是，如果消费者应用程序在过程中崩溃并重新启动，消费者会尝试从队列中获取消息并开始重新处理它，这不适用于我的情况。因为当消费者应用程序崩溃时，请求者将得到错误响应(或超时)。我知道MassTransit中
浏览 6提问于2021-11-18得票数 0
在过去，我在RabbitMQ中使用MassTransit。最近，我需要实现处理Amazon简单队列服务(发送和消费消息)的基础架构。选择MassTransit而不是本机工具，以防将来队列提供程序会发生变化。然而，我一直在为配置而苦苦挣扎(没有太多的文档，特别是针对MassTransit V7和SQS7的文档)。我想知道，是否可以配置MassTransit，使其在使用消息后将其从<e
浏览 11提问于2021-07-02得票数 0
1回答
是否有一种方法显式地告诉代理向队列的指定死信队列发送消息？
我知道，我们可以配置一个队列，在一定数量的重传尝试之后，将消息自动发送到DLQ。然而，在业务规则错误的情况下，当我们知道业务规则违反/格式错误消息时，在发送到死信队列前的X分钟内将该消息重传X次是没有意义的。我知道我可以显式地编写代码将其发送到死信队列，但是我
浏览 6提问于2022-02-18得票数 1
回答已采纳
我正在使用.NET /RabbitMQ的生产者/消费者场景中的2个核心控制台应用程序。我需要确保，即使没有消费者启动和运行，来自生产者的消息仍然成功排队。这似乎不适用于Publish() --消息只是消失了，所以我使用Send()代替。消息至少会排队，但是如果没有任何用户运行这些消息，所有消息都会在"_skipped“队列中结束。使用Send()，我的使用者确实可以工作，但是仍然有许多消息从漏洞中
浏览 1提问于2019-05-08得票数 1
可以将消息发布到带有过期TTL的RabbitMQ队列中:这样的消息将在TTL完成后过期，并且(如果设置了死信队列，则)移到死信队列中。
但是，是否可以用芹菜来指定这样的每条信息的TTL呢？注意，我不是在寻找一种指定任务到期的方法，而是寻找消息过期:我希望我的消息在队列中花费(一个可配置的)时间，然后才能最终获得
浏览 0提问于2014-11-18得票数 7
回答已采纳
我正在处理一个被配置为FIFO (第一个输入第一输出)的蔚蓝服务总线队列。我处理订单申请的状态如下：“待决”、“接收”和“发送”。到目前为止，它工作得很好，我发现的问题是，当“待定”或“接收”状态中的消息由于超时而失败并进入死信队列时。正确处理“已发送”状态中的消息，然后当支持团队将“待定”或“接收”状态消息重新发送到队列时，将正确地处理该顺序，而不是“已发送”。我可以想出几种控制这种情况的方法，例如，支持小组<em
浏览 5提问于2022-07-18得票数 2
回答已采纳
云服务器
ICP备案
实时音视频
即时通信 IM
云直播
腾讯云开发者
