masstransit 相关问题

是否应该与MassTransit的调解员一起发布作品？

Send方法适用于Mediator，但不适用于Publish方法。消费者什么也收不到。那是故意的吗？是否期望在更高版本中使用？

创建后是否可以将消费者添加到MassTransit的调解器中？

我注意到，当消费者添加如下消息时，它们会收到消息：var mediator = Bus.Factory.CreateMediator（conf => {conf.Consumer （（;;;）））;邮件不是...

将错误消息发送到具有Masstransit和Azure Service Bus的主题订阅死信队列中

[当主题的订户引发异常时，未处理的消息将落在{subscribername} _error队列中。给出示例：const string subsriberName =“ AnotherSubscriber”; cfg ....

没有此类主机-大众运输-Azure服务总线

这可能是非常基本的，但是由于某种原因，我无法使其正常工作。我正在使用大众运输Azure Service Bus软件包v 5.5.6连接到Azure上的服务总线队列。跟随质量...

MassTransit：如何在IRetryObserver中检索消息的内容

使用IRetryObserver，我正在监视和记录所有重试尝试及其最终结果（无论消息是否最终成功处理）。我想知道是否可以访问...

在公共交通中通过路由密钥拆分邮件

我想根据路由键将消息发送到适当的队列。从生产者应用程序开始，我的代码（相关部分）是：var options = serviceProvider .GetService ] >>>

在Autofac模块中测试MassTransit端点配置

我在Autofac模块中有一些终结点配置代码，该模块根据我要进行单元测试的约定来注册使用者。我不是要验证任何使用者的行为，我...

MassTransit 6.2.3中的可疑ConnectHandler扩展方法问题

Saga短暂异常记录为错误

我正在使用Masstransit 6.2。我正在使用Marten进行传奇存储，并使用serilog进行日志记录。我的传奇故事经常会出现数据库并发异常，但可以使用重试/重新传送来恢复。但是这些...

Abort MassTransit StartAsync

在服务的启动阶段，我们启动MassTransitClient订阅。启动在后台线程上运行。 void Startup（）{... var busProvider = serviceProvider.Get （）; ...

等待使用MassTransit完成版本的传奇，版本= 6.2.1.0

[从Web api控制器中，我想启动一个Saga，它将使用请求-响应模式调用其他Web api。 var sendToUri = new Uri（$“ {RabbitMqConstants.RabbitMqUri} {RabbitMqConstants ....

不能同时使用Bind和ConfigureConsumer

我在Asp.Net Core应用中使用MassTransit + RabbitMQ组合。下面的相关配置部分：公共IBusControl CreateBus（IServiceProvider serviceProvider）{var options = serviceProvider ....

使用StructureMap配置的MassTransit-ContainerScoped无法正常工作

我已经在我的StructureMap配置中使用ContainerScope配置了一个类X，但是由于某些原因，当应用程序最初启动并且MassTransit使用者使用初始消息时，它会创建...

RabbitMQ关闭时的大众运输重新连接策略

我有以下不同情况：情况1 RabbitMQ已启动。消费者启动并通过MassTransit正确订阅RabbitMQ。 RabbitMQ下降。 RabbitMQ上升...

在MassTransit上禁用循环消息消费>>

我已经创建了一个基本的演示pub / sub应用程序，该应用程序可通过MassTransit在localhost上运行。我要实现的是发布一条消息，所有订阅者都应该收到该消息。在...

MassTransit Azure ServiceBus强制连接使用HTTPS而不是AMQP

我们如何强制MassTransit使用HTTPS而不是AMQP连接到Azure Service Bus？我们的应用程序位于企业防火墙之后。它需要从Azure主题发送/接收消息。我们...

RabbitMQ的更好的设计方法是什么？

最近几周我一直在与RabbitMQ玩耍，并开发了以下设计模式生产者消息代理（rabbitmq）排队给消费者。我...

MassTransit Publisher没有引发异常

我有一个用Asp.Net Web API开发的MassTransit生产者/发布者。生产者只需将消息发送到Exchange->队列。公共异步任务 AddToQueue（int msgId，Message ...

MassTransit RabbitMq发送消息

发送/发布消息时，我无法弄清楚如何在我的GetSendEndpoint（））任务中指定Exchange和队列？根据MassTransit文档https：// masstransit-project ....

MassTransit：使用者有异常时引发其他错误。 “ IErrorTransport在ReceiveContext上不可用。”

我有一些使用者在已升级到MT 6.0.2以及Azure Functions 3和核心3的Azure功能中运行。当使用者中遇到错误时，消息不会发送到...