masstransit 相关问题

MassTransit 和 EventHub 消费者群体

在 C# 中，我们如何注册与 Azure EventHub 消费者组绑定的 MassTransit 消费者？ 我在文档中看到“指定的消费者组对于应用程序必须是唯一的，并且共享......

为什么在使用Mediator时在Saga中使用Request时会出现找不到调度程序的异常？

我正在使用 MassTransit 8.1.3 和 Mediator 传输，如下所示： services.AddMediator(x => { x.AddSagaStateMachine().InMemoryRepository(); }); 在我的传奇故事中，我...

大众交通中的服装信息消费

我有一个要求，我有两个具有相同代码库的 ASP Net Core 应用程序（A 和 B）。每个应用程序都会发布它使用和处理的一些命令。现在，当应用程序 A

使用 MassTransit 将服务注入队列消费者

我有一个配置如下的消费者 .ConfigureServices((hostContext, 服务) => { 服务.AddMassTransit(cfg => { cfg.AddConsumer (); ...

RabbitMQ 集群的 MassTransit 配置问题

我有一个 RabbitMQ 集群 xx.xx.xx.xx6、xx.xx.xx.xx.xx7 和 xx.xx.xx.xx8。我正在尝试使用 UseCluster 方法注册它们： BusConfigurator.UsingRabbitMq((上下文，配置器) => ...

MassTransit 单元测试和故障

我正在使用 MassTransit 8 和 AddMassTransitTestHarness 方法来连接一些测试。我有一个 IConsumer，在 Consume 方法中我故意抛出一个新的异常只是为了测试

从 Azure 服务总线接收 MassTransit 上带有空正文的消息

我正在尝试接收从具有标头但没有正文的服务总线发送的消息。这些消息不是使用 MassTransit 发送的，但我想通过 MassTransit 接收。 我收到此错误...

使用事务发件箱时间歇性丢失消息

我正在使用 MassTransit 事务发件箱模式。今天，我们遇到了一些问题，我发现有些消息没有传递给消费者。 问题是我们有 3 个应用程序，而且都在使用 sa...

大众交通消费者依赖注入

我有一个 dotnet core 控制台应用程序，希望将一个类注入到消费者中。 我在这里使用单个消费者设置了接收端点。 sbc.ReceiveEndpoint(appSettings.QueueUrl, ep =>...

无法在 Azure 容器应用程序中使用 ASB 缩小到零

我在容器中有一个 .NET 8.0 控制台应用程序，该应用程序部署到 ACR 并在 ContainerApps 上运行。 应用程序基于 MassTransit 构建，使用 Azure 服务总线队列。 效果很好，但我...

大众交通发布过滤器替换消息

MassTransit 是否允许构建发布过滤器，以便在发送之前可以用另一条消息替换原始消息？ 我们将 MassTransit 与 Azure 服务总线结合使用。有限制...

MassTransit：通过 Kafka 接收消息时避免推送到 RabbitMQ

我正在运行一个应用程序，该应用程序充当通过 RabbitMQ 和 Kafka 发送消息的消费者。它不产生任何东西。当应用程序运行时，我注意到通过 Kafka 收到的消息是......

使用 ha-mode=all 创建 Quorum 队列

我想提前道歉，但我对大众交通不太有经验。 我需要帮助创建仲裁队列并将 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...

RabbitMQ 根据不同环境提供多个队列

我正在开发 .net 6 Web API 中的一个项目。我创建了 2 个微服务：订购和生产。我设置成功了现在我有 3 个环境：开发、暂存和 UAT。对于

Kafka 和大众交通的 Sagas 模式

我已经使用 Kafka 和 Masstransit 几天了，只是偶然发现了 Sagas 模式。我正在考虑将此模式应用到我的应用程序中，但我不确定 Masstransit 是否支持 Sa...

在EventActivityBinder.Produce方法中发送消息密钥

我正在开发一个使用 Masstransit 与 Sagas 和 Kafka 的项目，只是偶然发现了一个问题。我正在尝试使用 EventActivityBinder.Produce 向某些 Kafka 主题生成消息。问题...