MassTransit是一个免费的,开源的,轻量级的Microsoft .NET框架服务总线。
包含属性的 xml 的 MassTransit Xml 反序列化
早些时候我问了一个关于如何反序列化 xml 消息的问题(发送机智 ActiveMq)。 我错过了一个事实,即如果包含 MassTransit.NewtonSoft,您可以使用 UseRawXmlSerializer()。 现在我可以
MassTransit:使用 RabbitMQ 将默认队列类型设置为仲裁队列
我们正在从使用经典镜像队列更新为使用仲裁队列。我们正在使用 MassTransit 6.0.0,我已经更新了所有对 ReceiveEndpoint 的调用以设置 x-queue-ty ...
Field 没有被 Json 忽略,Class 仍然显示在 MessageType 中
问题 #1 使用 [ExcludeFromTopology] 修饰 Message 类不会排除 MessageType 中的命名空间和类名。 问题#2 有些消息包含我不知道的字段...
Field 没有被 Json 忽略,Class 仍然显示在 MessageType |轨道交通 | Azure 服务总线
问题 #1 使用 [ExcludeFromTopology] 修饰 Message 类不会排除 MessageType 中的命名空间和类名。 问题#2 有些消息包含我不知道的字段...
MassTransit + Kafka - 故障消费者未被调用
我正在使用 MassTransit 8.0.10 和 Kafka 作为骑手,我想要完成的是处理错误条件下无法处理的消息,并对它们做一些事情(比如
MassTransit JMS 接收原始或 XML 格式的消息
我正在尝试从 JMS 队列(由 ActiveMQ 托管)获取 XML 消息。只要我使用 JSON 消息,它就可以完美运行,但我无法使用原始文本或 XML 消息。 我试过了
Serilog Sink with MassTransit - IBus 服务解析导致无限循环
我正在尝试为 Serilog 设置一个接收器,该接收器通过 MassTransit 发布日志消息。 当我尝试在启动时创建接收器时遇到问题。创建接收器会导致无限循环。 怎么...
我正在尝试使用公共交通事务发件箱模式,这是配置: 程序.cs: services.AddMassTransit(配置=> { 配置。
MassTransit 托管服务没有实现同步版本的处理(IDisposable)
我在 IIS 中托管的 ASP.NET Web 应用程序中使用 MassTransit。 看来当我停止应用程序池时,应用程序正在停止,Azure 服务总线已停止但最后一个薄...
我正在研究使用 Masstransit 的消费者,对于特定情况,我希望能够在给定处理状态的情况下重新排队消息。 我插入了 AddDelayedMessageScheduler() 和
我们如何使用 Masstransit 从 Azure 服务总线消费 FHIR 类型的消息?
我们在本地配置了 NHS 111 适配器,使用 Azure 服务总线推送数据 https://github.com/nhsconnect/integration-adaptor-111 所以当我们从 NHS 111 测试套件推送数据时,它发送 XML 作为
我有一个关于干净架构的问题。我知道使用外部资源应该在基础设施层完成。目前,我正在处理在 blob 中存储文件
Masstransit - RabbitMQ.Client.Exceptions.AlreadyClosedException 在处理重负载时
尝试发布 1M 左右的事件时,遇到以下异常。 处理 30k 事件时连接关闭。 即使我设置了限制,也只有一个频道被创建和使用......
AWS Lambda 无法连接到 AWS SQS(VPC 端点)
我有一个 AWS Lambda 通过安全组连接到 VPC 中的 RDS 实例。将我的 AWS Lambda 放在 VPC 中意味着它无法访问公共互联网,除非我创建一个 VPC 端点。硅...
升级到 v8 后,MassTransit + Azure 服务总线身份验证问题
我有一个 dotnet 6 应用程序,我正在尝试从 MassTransit v7 升级到 v8,但是当我这样做时,我遇到了 Azure 身份验证问题(Azure.Identity.AuthenticationFailedException:ManagedIdentityCredential
在 MassTransit 中,消费者如何注册到多个端点? 公开课留言 { 公共对象有效载荷 { 得到;放; } } 公共类 Consumer1:IConsumer { //...手...
与 Azure 服务总线一起使用时获取 MassTransit.RequestTimeoutException
我是新手 Masstransit,打算将 Durable Future 和 Routing slip 模式与 Azure 服务总线一起应用。 具有如下定义的控制器的网络应用程序: app.MapPost("/订单/提交",
在 Sagas 中使用 MessageData 的正确模式是什么
在 Saga 中使用 Claim Check 模式时,或者当消息数据需要传递给其他消息时,正确的使用方法是什么? 我可以看到的两个选项是: 迪斯里...
我正在尝试创建一个状态机,我想从这个状态机发送多个请求。请求定义如下: 公共请求 我正在尝试创建一个状态机,我想从这个状态机发送多个请求。请求定义如下: 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 状态机不支持具有相同响应类型的两个请求。
Masstransit 作业服务消费者并发限制为每分钟 2 个请求
我正在测试 Masstransit 基于 JobConsumersSample 的 JobConsumer 设置。当我使用 masstransit/rabbitmq 图像在本地运行时,一切正常,作业按照配置运行...