MassTransit是一个免费的，开源的，轻量级的Microsoft .NET框架服务总线。
MassTransit 是否允许构建发布过滤器，以便在发送之前可以用另一条消息替换原始消息？ 我们将 MassTransit 与 Azure 服务总线结合使用。有限制...
MassTransit：通过 Kafka 接收消息时避免推送到 RabbitMQ
我正在运行一个应用程序，该应用程序充当通过 RabbitMQ 和 Kafka 发送消息的消费者。它不产生任何东西。当应用程序运行时，我注意到通过 Kafka 收到的消息是......
我想提前道歉，但我对大众交通不太有经验。 我需要帮助创建仲裁队列并将 MassTransit 8.0.15 的队列“ha-mode”设置为“all”...
MassTransit Consumer 不消费 Worker 中的消息
我有一项服务将消息发布到“ta-emails”队列（SQS） 我有一个正在运行的 Worker，它必须消耗这些消息。 公共类 AdvisorRegisteredConsumer：IConsumer<
MassTransit ConfigureBatchPublish - 发送重复批次a
我无法理解ConfigureBatchPublish 实际在做什么。 我尝试使用它的方式是在公共交通巴士上进行此配置： h.ConfigureBatchPublish(...
有没有办法让 MassTransit 放弃错误消息而不是转发到错误队列/死信
我正在尝试在基于 Azure 服务总线的非常可靠的基于消息的系统中使用 MassTransit。 当消息处理发生错误时，MassTransit 会将消息移至错误/故障队列。 我...
隔离模式下的MassTranist Azure 服务总线无法获取上下文的deliveryCount 属性
为什么当我调查 MassTransit 对象的 ReceiveContext 时可以看到 DeliveryCount，但无法将其作为变量拉入？ 我尝试过查看 GetRetryAttempt()、GetRetr...
我正在开发 .net 6 Web API 中的一个项目。我创建了 2 个微服务：订购和生产。我设置成功了现在我有 3 个环境：开发、暂存和 UAT。对于
我已经使用 Kafka 和 Masstransit 几天了，只是偶然发现了 Sagas 模式。我正在考虑将此模式应用到我的应用程序中，但我不确定 Masstransit 是否支持 Sa...
在EventActivityBinder.Produce方法中发送消息密钥
我正在开发一个使用 Masstransit 与 Sagas 和 Kafka 的项目，只是偶然发现了一个问题。我正在尝试使用 EventActivityBinder.Produce 向某些 Kafka 主题生成消息。问题...
如何为通过 AddConsumer() 创建的队列配置 PurgeOnStartup？
防止 XY 问题的一些背景： 我正在开发一个系统，其中每 X 分钟发送一条消息以在服务中的 Pod 上运行作业。当所有 pod 都不健康或重新启动时，这些
我正在尝试处理 MassTransit，我有许多带有 StableDefussion 的服务器，它们接受在队列中生成图像的任务 但事实是不同的服务器有不同的...
我已经关注大众交通几周了，我对它的可能性很好奇。但是，我似乎无法完全正确地理解这些概念。 预期行为 我想要
在学习中介者模式时，我遇到了大众交通。 虽然我对理论有足够的理解（我希望），但我正在努力寻找支持的代码示例/文档......
我有一个处理消息的 C# 应用程序，需要为收到的每条消息调用 python 代码。但是，如果我并行运行处理，我的 docker 容器就会崩溃并显示 139 退出代码。怎么可以...
我在 MassTransit 中有一个消费者，它似乎想默认监听队列上的消息。它创建一个带有订阅的主题和一个队列。消息从订阅者转发...
.NET - MassTransit - 所有人的 StateMachine 故障消息
我有一个关于公共交通图书馆中的 statmachine 的问题。这是我的代码： 公共活动？请求{得到; } 公共活动？开始{获取; } 公开活动<
我正在使用 https://masstransit.io/ 库，发送 2000 条消息平均使用 100% CPU 15 分钟。 一开始我以为是因为消息要求的工作，但后来我尝试了
公共交通中请求客户端和 RoutingSlip 快递的典型用法的差异
我知道对于分布式和顺序服务，我们正在使用 RoutingSlip courier。想象一下，我有一个场景，我想要一个请求发布者，我们将其命名为 apiPublisher，它想要调用数据库...