masstransit 相关问题

MassTransit是一个免费的,开源的,轻量级的Microsoft .NET框架服务总线。

MassTransit / RabbitMQ中的消息持久性

我有2个应用程序,一个事件发布一个,事件消费者一个。发布者使用SimpleInjector:container.AddMassTransit(x => {x.AddBus(()=> Bus.Factory ....

回答 1 投票 0

在发布者端在SimpleInjector中为MassTransit建立队列

我有2个应用程序,一个事件发布一个,事件消费者一个。发布者使用SimpleInjector:container.AddMassTransit(x => {x.AddBus(()=> Bus.Factory ....

回答 1 投票 1


如何向MassTransit断路器添加异常过滤?

我正在尝试将异常过滤添加到MassTransit断路器。我只想将CircuitBreaker用于TimeoutExceptions。这可能吗?异常过滤可用于重试/ ...

回答 1 投票 0


交易发件箱是否高度可靠

我想知道事务发件箱如何工作以及MT如何保证数据库事务和消息发送操作的一致性。在aspnetcore MVC示例中,当数据库事务...

回答 1 投票 0

MassTransit重试策略抛出System.NullReferenceException:

由于某种原因,我无法按照文档中的示例在我的使用者上使用重试,我只是向我的使用者添加了一个简单的r.Interval <>,但是在构建时失败了...不确定为什么要使用服务...。

回答 1 投票 0

MassTransit / Rabbit MQ版本兼容性

MassTransit版本在发布之前是否已针对Rabbit MQ的特定版本进行了测试和认证?如果是,是否发布了此信息?

回答 1 投票 0

在Masstransit框架上的Azure队列接收器中获取Api响应

我是Masstransit的新手用户,我一度陷入困境。下面是我的架构。 1)我有WebApi COntroller,它正在使用以下代码在azure队列中发送消息。如果(...

回答 1 投票 0

是否可以从MassTransit中的错误队列中读取和删除消息

我们正在使用.Net Core / RabbitMQ / MassTransit,并且我有一个Consumer [OrderCreatedEvent]运作良好。我想要一种错误恢复机制,在启动应用程序时,我想... ...>

回答 1 投票 0

我如何使用autofac在Rabbitmq masstransit中向消费者注册通用装饰器?

下面的代码注册使用者接口实现,并注册通用使用者接口的通用装饰器。 builder.AddMassTransit(); builder.Register(context => {...

回答 1 投票 0

无法通过masstransit访问Azure服务总线队列中的接口类型的值

我正在使用masstransit将消息发送到azure服务总线队列,其中消息模型接口本身具有另一个接口。我的消息架构如下:公共接口IMyMessage {...

回答 1 投票 1

是否可以在MassTransit Saga中关联不基于ID的消息?

是否有可能将传入消息与ID或属性不具有1到1的相关性的佐证相匹配?我正在做类似以下的事情,但是CorrelateBy似乎不...

回答 1 投票 0

MassTransit的重试功能块是否消耗了其他消息?

给出MassTransit的并发性配置为1,并且对于失败的消息具有1小时的重试策略,并且队列以2条消息开始并且使用第一条消息失败:是否...

回答 1 投票 1

将消息发送到具有大众运输的天蓝色服务总线主题中的特定订户组

我是天青服务公交车和大众运输的新手。我正在寻找针对特定情况的解决方案。我有一个具有多个订户的azure服务总线主题。订户将基于以下内容接收消息:

回答 1 投票 0

Saga中的大众运输处理故障

我正在尝试处理Saga实例内的特定故障,如https://masstransit-project.com/MassTransit/usage/exceptions.html#faults中所述。在myStateMachine类中,我具有:Event(()=&...

回答 1 投票 0


Masstransit失败的主机连接

我使用MassTransit.AspNetCore软件包将masstransit集成到asp.net核心。因此,我的Startup.cs类中包含以下代码:IBusControl CreateBus(IServiceProvider serviceProvider){...

回答 1 投票 0

MassTransit端点名称在ConsumerDefinition中被忽略

ConsumerDefinition文件中的EndpointName属性似乎被MassTransit忽略。我知道使用了ConsumerDefinition,因为重试逻辑有效。我如何获得不同的命令来...

回答 1 投票 0

SqlConnection ExecuteAsync在Linux上挂起,但在Windows上不挂起

ASP.Net Core我的代码比调用var resp = await conn.ExecuteAsync(“ procedureName”,sqlParams,commandType:CommandType.StoredProcedure).ConfigureAwait(false)当我在...上启动我的应用程序时]]

回答 1 投票 0

© www.soinside.com 2019 - 2024. All rights reserved.