masstransit 相关问题

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

MassTransit Saga 中两个请求的响应类型相同

我正在尝试创建一个状态机,我想从这个状态机发送多个请求。请求定义如下: 公共请求 我正在尝试创建一个状态机,我想从这个状态机发送多个请求。请求定义如下: public Request<StageState, ICloseStage, ICloseStageRequestSuccess, IRequestFailed> CloseStageRequest { get; private set; } public Request<StageState, IPublishStage, IPublishStageRequestSuccess, IRequestFailed> PublishStageRequest { get; private set; } 两个请求可能在 Response2 中得到相同的响应。但是,当我运行状态机时,出现以下错误: System.ArgumentException:已添加具有相同键的项目。键:IRequestFailed 所以,我想这是因为我在两个请求中都使用了IRequestFailed。这是设计使然的行为还是有解决方法,以便我可以在两个请求中使用此响应类型?我真的需要这样使用它,因为IRequestFailed在状态机中对所有请求进行了统一处理,我打算添加更多请求 提前致谢。 MassTransit 状态机不支持具有相同响应类型的两个请求。

回答 1 投票 0

Masstransit 作业服务消费者并发限制为每分钟 2 个请求

我正在测试 Masstransit 基于 JobConsumersSample 的 JobConsumer 设置。当我使用 masstransit/rabbitmq 图像在本地运行时,一切正常,作业按照配置运行...

回答 0 投票 0

将 MassTransit 抽象为类库

我有一个类库项目,它将包含所有 MassTransit 配置、IBusControl、DTO、队列和交换配置。但是,消费者类需要在项目中...

回答 0 投票 0

查询MassTransit状态机信息

是否可以使用 MassTransit 使用的 DbContext 将 StateMachines 存储为常规 DbContext? 在我的应用程序中,我们要实现以下场景(删除验证和错误处理......

回答 0 投票 0

准备好使用 Masstransit 时使用消息?

我在这里可能是错的,但是当我准备好时,我看不出有任何方法可以使用 Masstransit 来消费消息,而只是有一个消费者类,当我们确实有消息要消费时被调用? 是...

回答 1 投票 0

MassTransit RabbitMQ 流

我想尝试使用 MassTransit 的 RabbitMQ Streams。 目标是仅为队列的子集定义配置。 当消费者是

回答 0 投票 0

MassTransitStateMachine 在调用 Cancel 事件时不执行 During Block 语句,如果 Consumer 发生任何错误

我是微服务分布式事务处理的新手。 我正在构建一个基于微服务的应用程序,其中包含两个通过 RabbitMQ 代理进行通信的微服务。 我正在尝试...

回答 0 投票 0

MassTransit:在 Saga 状态机中取消的正确方法

我有一个关于取消使用 RabbitMQ 的 Saga 状态机实例的问题。我有这种情况: 我有一个公开端点的 API,该端点(当被击中时)发布初始消息...

回答 1 投票 0

masstransit与asp.net core 3.1的整合

我使用dotnet core创建了一个新的webapi项目。我使用ubuntu 19.10使用.net core 3.1版本。这是我的proj文件。

回答 1 投票 0

MassTransit和RabbitMQ,消息的历史。

我的问题更多的是架构上的,而不是程序上的,但我认为它将适合S.O.的T&C.我们有一个应用程序,它负责发送批量电子邮件。架构组成为...

回答 1 投票 0

通过消息服务传输一个实体对象,改变它并将其附加回来。

我通过MassTransit转移一个实体对象,改变一些属性,然后返回。当然这涉及到后台的序列化deserialization,由MassTransit自动完成 ...

回答 1 投票 0

如何在asp.net Core容器化项目之间共享类定义与docker。

所以,我有一个架构,有几个不同的 "后端 "asp.net核心web api's。我使用Masstransit和rabbitmq来促进容器间的通信。使用MassTransit,服务需要一个 ...

回答 1 投票 0

RoutingSlipActivityCompleted不触发。

我添加了一个消费者来观察路由滑移事件,但是没有达到预期的效果。RoutingSlipCompleted消费者总是被触发,RoutingSlipActivityCompleted和RoutingSlipActivityFaulted ...。

回答 1 投票 0

Azure 服务总线上的 MT。为什么我看到System.InvalidOperationException。连接关闭时无法创建会话?

我正在使用 MT 5.5.6 & Azure 服务总线,我偶尔会在我的所有服务中收到以下异常抛出。System.InvalidOperationException: 当连接......时,无法创建会话。

回答 1 投票 0

Masstransit RabbitMQ发布者未能发布 "正确 "的合同。

我一直在使用Masstransit和RabbitMQ创建消息合同以实现两个.NET核心Web API之间的通信,我已经玩了一段时间,我偶然发现了以下内容。...

回答 1 投票 0

正运,返回消耗的信息。

我对Masstransit是个新手,我不太清楚如何配置这个。有没有办法将消耗的消息返回到我调用Consume方法的地方?Consume方法返回...

回答 1 投票 0

MassTransit & Amazon SQS - EventType被创建为队列。

我刚刚从RabbitMq迁移到Amazon SQS上。我不希望发生的一件事是,当我使用docker & IHostedService启动时,消息类型被创建为队列:公共......。

回答 1 投票 0

Masstransit - Rabbit MQ虚拟主机。

string uri1 = @"rabbitmq:/myusername:mypassword@myipmyvirtualhostmyqueue"; 我一直得到一个ConfigurationException was unhandled. ...

回答 1 投票 2

MassTransit消费者从未收到信息

我正在按照在ASP.NET Core应用程序中使用RabbitMQ和Autofac的MassTransit的文档构建一个演示应用程序。我的程序代码: namespace MessageDemo { public ...

回答 1 投票 0

Masstransit配置通用消费者

我正在使用MassTransit在我们现有的应用程序中集成一个消息代理。我们已经实现了一种命令处理程序,它有通用的实现,就像这样:... ...

回答 1 投票 0

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