构建我的第一个Saga状态机实现。我已经编写了一个接口nuget包来在执行和发布这些事件的服务之间共享Saga事件和命令。我通过基类为每个事件/命令实现了Masstransit CorrelatedBy< Guid>。public class BaseSagaEvent : CorrelatedBy<Guid>, IBaseSagaEvent
浏览 3提问于2020-06-05得票数 0
2回答
当saga被实例化时，它将另一个事件发布到MassTransit.The，新事件由执行某些业务逻辑的消费者获取，并将两个由此产生的事件中的一个发布到步骤3中产生的事件。触发saga中的状态更改。以下是业务逻辑代码：public interface IExternalCheckRequest: Correlated
浏览 19提问于2022-03-04得票数 0
回答已采纳
1回答
该项目的目标是定期检查一个文件夹(或多个文件夹)中的新文件，并对它们进行处理(主要是通过将数据存储在DataBase中)。
我想为调试目的使用日志记录服务，我偶然遇到了Serilog。我设法将它添加到Quartz和EF中，但我在将它添加到地铁上时遇到了问题。但是现在我想把它添加到我的MassTransit自动名称中，但是我很难弄清楚它。在这个线程中，我发现应该添加Serilog (或任何其他记录器) ，方法是将MassTransit LogContext配置为so LogContext.
浏览 6提问于2021-08-13得票数 0
回答已采纳
我一直在使用MassTransit，真的很喜欢它。但是，在默认情况下，它使用一些特定于MassTransit的JSON包装所有RabbitMQ有效负载/消息。这使得与非.NET服务交换消息变得困难。我知道MassTransit可以被任何语言解析，但是MassTransit是.NET特有的东西，在我的非.NET服务中，我希望避免添加特殊的逻辑来处理JSON生成的消息。有<e
浏览 2提问于2018-03-29得票数 8
1回答
将服务总线实现隐藏在接口后面
、、、、
我目前正在致力于一个项目，允许第三方连接到我们产品的消息代理。其任务是提供一个供这些第三方使用的库。我希望能够打包地铁或NServiceBus，但我想把这些细节隐藏在接口后面。readonly MassTransit.IBusControl _busControl;
public c
浏览 0提问于2019-01-16得票数 0
回答已采纳
我们已经开始了从MassTransit 2.9.5 (附带信使加载项)迁移到MassTransit 4.0.1的旅程。事情进展缓慢，但好吧，我对新的(对我们来说)功能很兴奋.但我和信使碰壁了。<Guid> public Guid CorrelationId { get; set; } }
pu
浏览 3提问于2018-02-10得票数 1
回答已采纳
我很难让MassTransit (v7.3.1)使用运行在Docker容器中的ActiveMQ Artemis2.19.0使用已计划好的事件来工作。所有事情都可以正常工作，但是不管我指定什么延迟，事件的发布都不会延迟。下面是我的测试代码，使用测试工具进行一次绿色测试，使用ActiveMQ进行一次失败<em
浏览 14提问于2022-03-08得票数 0
回答已采纳
当mt试图从队列接收消息时，我会得到以下奇怪的错误。at System.Guid.TryParseExactD)
at MassTransit.Pipeline.Filters.ConsumerMessageFilter`2.GreenPipes.IFilter<Mas
浏览 9提问于2022-12-01得票数 0
回答已采纳
我一直试图在NewRelic中为MassTransit设置自定义度量标准，类似于NServiceBus与NewRelic的工作方式。使用NewRelic 文档似乎很容易实现这一点。到目前为止，我还没有在GitHub上检出GitHub代码，而是为MassTransit设置了一个简单的插装文件，但这只包含消息发送，但我确实希望收到消息，但我似乎找不到第一个与传输实现无关的拦截。，我已经更新了新的包，所以
浏览 6提问于2015-10-13得票数 0
回答已采纳
1回答
我使用MassTransit.Kafka批量生产和消费消息。看起来像是NewtonSoft去具体化错误，但一切都是根据MassTransit文档完成的。我曾尝试将UserEvent转换为接口，因为文档中的每个模型都是接口，但这没有帮助。EventId { get; set; } = Guid.NewGuid(); public string Test{
浏览 50提问于2021-04-11得票数 0
回答已采纳
MT (此处：)表示，对于使用基于容器的配置测试消费者，我们应该这样做： .AddMassTransitTestHarness{ })我已经安装了MassTransit
浏览 13提问于2022-11-23得票数 1
回答已采纳
MassTransit指出，我们应该为消息契约使用接口：
使用POCO而不是接口的缺点是什么?在使用MassTransit</e
浏览 2提问于2017-06-05得票数 24
我正在尝试设置一个MassTransit请求/响应场景。问题是，信息永远不会到达消费者手中。我在PublishRequest上得到了一个“超时等待响应”错误。日志文件中没有出现其他错误。例外情况：
等待响应的超时，c：\ d:\BuildAgent-03\work\8d1373c869590c5b\src\MassTransit\Request
浏览 2提问于2012-12-03得票数 3
回答已采纳
1回答
我正试图将结构图作为DI容器与我的公共交通代码集成。我试图将已签名的结构映射程序集降为3.1.6.186，以确保它与结构映射的未签名版本相同，但这似乎会给MassTrans
浏览 1提问于2015-11-20得票数 1
回答已采纳
我正在为一个家庭作业创建一个程序，它使用一个接口来计算火车旅行的成本：
public interface MassTransit {
public void getRoundTripCost(int leave,int return_time);
}//end of MassTransit
浏览 1提问于2012-10-26得票数 0
回答已采纳
在迁移到Masstrasit8.0.3之后，ScopeFilter确实允许响应并结束发送中的使用者进程(ConsumeContext.)方法。在我们的例子中，我们有一个带有中介设置的缓存作用域过滤器。在Masstransit 7.x中，它起作用。在Masstransit 8上面写着“信息没有被消耗”
解决这个问题的一种方法是在消息有效负载中写入结果，让使用者首先检查缓存结果。但是，
浏览 44提问于2022-08-03得票数 1
我的项目目标是.NET Core2.2。 });
导致问题，因为它需要MassTransit.EntityFrameworkCore6.2.5 (然而，它使用的是Microsoft.EntityFrameworkCore.Relational (3.1.3
浏览 1提问于2021-01-06得票数 1
回答已采纳
在将消息发布到队列之前，我正在尝试在消息中添加额外的标头。在创建总线控制时，我无法添加UseSendFilter()和UseConsumeFilter()。请在下面查找消息有效负载和总线配置。请注意，目标框架是dotnet v4.8using System;{
public interfaceIPublishMessage : CorrelatedBy<Guid&g
浏览 0提问于2021-05-05得票数 0
有没有办法在IHealthCheck中实现MassTransit。接口IHealthCheck在.net Core2.2预览3 ()中引入
浏览 0提问于2018-10-21得票数 2
回答已采纳
云服务器
ICP备案
对象存储
云点播
实时音视频
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号