masstransit 相关问题

在MassTransit中使用ConfigureEndpoints方法时，有没有办法配置一个特定的消费者？

我有很多消费者，我不想手动配置每个消费者，所以我使用方法AddConsumers和ConfigureEndpoints。现在我需要为其中一个消费者配置一个重复策略。...

使用MassTransit发布到Azure服务总线会导致错误。

我是MassTransit和Azure服务总线的新手。我正在尝试使用一种架构，在该架构中，RabbitMq 或 Azure 服务总线被用于 .NET Core 3.1 API。我有RabbitMq部分 ...

MassTransit.AmazonSQS。是否可以在总线启动后，将receiveendpoint中已经存在的SQS队列订阅到一个SNS主题？

我正在用AmazonSQS运行一个MassTransit配置。在我的程序中，我首先创建了一个带有队列 "input-queue1 "的receiveenpoint，我将这个SQS队列订阅到一个名为 "topic1 "的SNS主题，然后......

在MassTransit中使用ConfigureEndpoints方法时，如何丢弃故障消息？

本文提供了一个手动配置端点时的例子。就像这样：cfg.ReceiveEndpoint("input-queue", ec => { ec.DiscardFaultedMessages(); }); 但我已经 ...

测试活动补偿MassTransit

我想测试Activity中的补偿逻辑，但我不知道如何在测试中启动补偿方法。我有一个活动，它应该抛出一个异常，如果某件事情没有...

在没有MassTransit nuget的情况下实现MassTransit CorrelatedBy<Guid>接口。

构建我的第一个Saga状态机实现。我已经写了一个接口nuget包，以在作用于和发布这些事件的服务之间共享Saga事件和命令。我实现了...

通过基类发布时未执行任何使用者代码

我有一个基类IntegrationEvent和所有其他从其继承的业务事件。公共抽象类IntegrationEvent {公共Guid ID {get;私人套装； } public ...

MassTransit与RabbitMQ之间的通信

我想使Java应用程序和.net应用程序通过队列进行通信。我想使用MassTransit，但在Java中不可用，因此在Java代码中，我们直接将RabbitMQ用于...

我们可以通过masstransit一起使用RabbitMQ和Mediatr吗？

我创建了一个微服务应用程序，该应用程序使用MassTransit和RabbitMQ进行通信。每个微服务都是使用干净的架构开发的，因此我们在每个微服务中都有MediatR ...

MassTransit-AWS SQS / SNS-向SNS添加标签

我需要以维护SNS标签的方式配置MassTransit库。我可以看到为创建的SQS队列配置标签的位置-并且可以用作...

Masstransit GetResponse

我无法完成这项工作。我尝试实现Masstransit的响应模式。我100％肯定只缺少一个细节。消费者收到我的消息，但是我在...

在大众运输中使用带有请求/响应的主题

我正在将Masstransit dotnet核心v6.3.1与RabbitMQ v3结合使用。我的情况是从api网关向其他服务发送请求。服务按主题使用，并且网关对每个请求使用不同的主题。我是...

通过MassTransit发布者/消费者传播W3C跟踪上下文

正在尝试支持从http调用->发布者->使用者-> MassTransit中的http调用传播W3C跟踪上下文traceId和spanId属性（只是为了使它们显示在日志/ seq中，用于...]]

MassTransit发送和发布

Masstransit的发送和发布方法之间有什么区别？你能举个例子解释吗？我在记录更新过程之后使用“发送”。在...

Masstransit发布的消息从队列中消失

在流程A中，我正在使用Bus.CreateRequestClient 创建客户端，然后使用client.GetResponse （请求）从流程B获得响应。在流程BI中...

SignalR客户端未通过Masstransit接收消息

我在通过MassTransit和SignalR Startup向客户端发送消息时遇到问题：// SignalR services.AddSignalR（）。AddMassTransitBackplane（）; #region MassTransit RabbitMq ...

MassTransit更改交换类型问题

我想在Masstransit中更改交换类型。我的示例代码块如下。 _bus = BusConfigurator.Instance.ConfigureBus（_massTransitSettings，（cfg，host）=> {...

是否可以定义一个单独的传奇，将处理许多消息

我的团队正在考虑是否可以将大众运输作为RabbitMq（相对于NServiceBus）中Sagas的主要解决方案。我承认我们的经验是，像masstransit和nserviceBus这样的解决方案是最少的...

masstransit和多个总线实例

根据MT文档，每个总线实例应具有不同的队列名称。我是否可以正确地假设以下配置正确？什么将WebApi和后端队列连接在一起？ ...

如何通过Masstransit初始化Rabbitmq？

我尝试按照指令https://masstransit-project.com/usage/transports/rabbitmq.html#cloudamqp中的说明通过masstransit实现Rabbitmq，但是Bus（IBusControl）没有Factory方法。 Bus.Factory ....