masstransit 相关问题

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

MassTransit如何在单元测试中设置超时?

我正在使用MassTransit在两个微服务之间交换消息,并且我有一个消费者在收到命令消息时发布事件。在添加单元测试以覆盖此消息时...

回答 1 投票 0

为什么“等待发布 “悬挂/未完成/未完成

下面这段代码已经工作了一段时间,它突然停止了返回:await availableChangedPublishEndpoint .Publish (...

回答 1 投票 3

无法使用SSL来使用MassTransit和cloudamqp

我一直在努力弄清楚我是如何配置MassTransit以及我们新的专用cloudamqp实例来使用SSL(注意:一切都在没有SSL的情况下工作)。我尝试添加...

回答 1 投票 0

MassTransit:如何向特定消费者发送消息?

对不起,如果我的问题很愚蠢,我是MassTransit的新手。我的系统由服务器和多个客户端设备组成。我想从服务器向特定客户端或一组...发送消息

回答 1 投票 0

MassTransit和广播

我试图在多个应用程序之间启动并运行消息传递系统。我有一个运行RabbitMQ的实例,看起来没问题。我可以将多个订阅者/发布者连接到...

回答 1 投票 2

MassTransit:合同类的模式和实践

微服务架构的常见建议是避免在微服务之间共享消息类。 MassTransit在发送/接收消息时严重依赖.NET类型信息,因此......

回答 1 投票 1

如何在MassTransit中配置多个重试策略

我想为特定的消费者提供两个单独的重试策略。一个用于HttpRequestException和SocketException,另一个用于自定义DatabaseException和未处理的SqlException。我想这样做......

回答 1 投票 1

如何使用MassTransit测试工具来测试使用构造函数依赖注入的Consumer?

我有一些消息使用者通过构造函数接受依赖,我想在单元测试中覆盖它们。 MassTransit的测试工具是否提供了一种注册消费者的方法......

回答 1 投票 1

如何在MassTransit IConsume中使用Autofac依赖注入

我正在尝试将DI与我的消费者类一起使用而没有成功。我的消费者类:公共类TakeMeasureConsumer:IConsumer {private IUnitOfWorkAsync _uow;私人的 ...

回答 1 投票 7

Mass Transit在轻负载下跳过命令

我最近建立了一个处理命令的简单Mass Transit服务。如果我一次发送3个命令它正确消耗前2个,那么第三个被放在* _skipped队列上。我......

回答 1 投票 1

RabbitMq - ConversationId vs CorrelationId - 哪个更适合跟踪特定请求?

RabbitMQ似乎有两个非常相似的属性,我不完全理解它们的区别。 ConversationId和CorrelationId。我的用例如下。我有一个网站......

回答 1 投票 1

使用MassTransit连接到ActiveMQ时,无法将连接器设置为AMQP

使用MassTransit我正在尝试使用AMQP连接器连接到ActiveMQ。 MassTransit配置为使用OpenWire连接器连接到端口61616.使用...创建ActiveMq的本地容器

回答 1 投票 1

如何使用MassTransit从RabbitMQ DeadLetter队列中检索消息?

我试图在一段时间后使用MassTransit和RabbitMQ收到消息时通知用户。根据我的阅读,当消息是...时,使用TimeToLive属性设置超时。

回答 1 投票 0

RabbitMQ .Net核心

要在.net核心中配置rabbitmq使用者,我会看到控制台应用程序的示例。我不确定生产就绪的应用程序可以将控制台应用程序作为独立的Rabbitmq Consumer。 ...

回答 1 投票 0

MassTransit Azure Service Bus,设置定期计划

是否可以通过在Service Bus上运行的MassTransit设置邮件传递的定期计划?如果是这样,有没有可用的示例代码?或者,建立类似于......的服务是否更好?

回答 1 投票 0

如何在正在运行的IBusControl上添加发布消息配置

我正在使用带有RabbitMqTransport的MassTransit。假设我使用以下命令运行IBusControl:var control = Bus.Factory.CreateUsingRabbitMq(c => {var host = confgurator.Host(config.BuildHostUri(),h =&...

回答 1 投票 0

MassTransit.ActiveMQ是netstandard吗?

我在我的产品中使用MassTransit。我必须使用ActiveMQ。包含MassTransit.ActiveMQ包的项目面向netstandard2.0。我不想改变它,但......

回答 1 投票 0

为什么要为事件接口层次结构中的每个级别创建订阅?

我试图通过使用masstransit和azure服务总线来了解如何正确地发布和使用事件。我想使用接口作为我的消息合同,我的事件继承了一个层次结构......

回答 1 投票 0

使用XUnit对MassTransit Consumer进行单元测试

我的团队刚刚开始使用MassTransit,我们正试图弄清楚IConsumer实现的单元测试是如何工作的。 MassTransit文档不完整,所有......

回答 1 投票 2

如何使用Serilog.Enrichers.MassTransit

我使用的是MassTransit 5.3.2,MassTransit.SerilogIntegration 5.3.2和Serilog.Enrichers.MassTransit 1.1.0。我注意到我有可能在几个地方添加Serilog浓缩剂。两个......

回答 1 投票 0

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