masstransit 相关问题

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


我无法解释以下错误:

services.AddMassTransit(x => { x.AddSagaStateMachine<MonitoringJobStateMachine, MonitoringJobState>() .InMemoryRepository(); x.UsingRabbitMq((context, cfg) => { cfg.Host(new Uri(rabbitHost), h => { h.Username(rabbitUser); h.Password(rabbitPass); }); cfg.UseDelayedMessageScheduler(); cfg.ReceiveEndpoint(sagaQueue, e => { e.StateMachineSaga( context.GetRequiredService<MonitoringJobStateMachine>(), context.GetRequiredService<ISagaRepository<MonitoringJobState>>()); }); }); });

回答 1 投票 0


回答 2 投票 0

回答 1 投票 0






.Net 8 - MassTransit/RabbitMQ:根据路由键路由消息

我有三个微服务:ImageService、ProductService 和 UserService。 ImageService 存储图像并为其他两个(甚至更多)服务发布消息。这些消费者必须拦截...

回答 1 投票 0

使用 MassTransit 与 postgres 传输和 EF Core 进行持久化时如何实现消息重复数据删除

当队列消息具有共同的关联 ID 时,如何确保不存在重复的队列消息?当队列中已存在带有

回答 1 投票 0

如果消费者抛出异常,为什么大众交通要确认消息?

我使用卡夫卡公共交通。我认为大众交通会处理我的消费者异常,而不是确认消息。 消费者将消息保存在收件箱中,如果数据库不可用,例外...

回答 1 投票 0

如何使用大众交通响应

项目 版本 ...

回答 1 投票 0

MassTransit 和 RabbitMQ:为消费者实现重复消息检测

我正在运行多个服务,它们都引用相同的消息契约库。 服务在 MassTransit 上发布事件。 我几乎经常在

回答 1 投票 0

尝试在 MassTransit 中设置请求/响应,但遇到依赖注入问题

因此,我尝试在 MassTransit 中设置请求/响应,但遇到了依赖项注入问题,我不知道它是什么,但我将提供与该问题相关的代码。 这是

回答 1 投票 0

如何模拟 ExecuteUpdateAsync 方法

如何在 EF Core 7.0 中为 ExecuteUpdateAsync 编写单元测试用例。 例如,像 GetAll 方法一样,我们可以如下模拟。我可以模拟executeupdateasync 方法吗? repositoryMock.Setup(x => x.GetAll()).

回答 1 投票 0

MassTransit SendFilter 无法停止消息发送

我在多租户应用程序中将 MassTransit 与 RabbitMQ 结合使用。我使用 IFilter 实现了自定义发件箱模式,该模式应该只将消息保存在我的数据库中,但我发现它也......

回答 1 投票 0

如何在实体框架中保留 MassTransit 状态数据?

我有一个使用 MassTransit 的工作状态机,但是,我想使用 EF Core 持久存储状态。我按照 MassTransit 网站上的指南进行操作,但它不起作用,它确实...

回答 3 投票 0

公共交通死信与 Azure 服务总线

我已经将公共交通与rabbit mq和.NET 6一起使用了一段时间,现在对于另一个项目,我正在尝试使用Azure服务总线。 我已经阅读了文档到一定程度,并且我了解...

回答 1 投票 0

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