masstransit

0热度

1回答

所以我一直在尝试使用内存中功能编写一个测试公共交通的测试。我想知道人们的做法是等待消费者执行。在下面的例子中使用睡眠，或者我也尝试了一个while循环，但不是任何一个迷，任何更好的想法？我基本上想检查消费者是否被执行。 [Fact] public async Task SomeTest() { var busControl = Bus.Factory.CreateUsingInMem

0热度

1回答

MassTransit中的总线队列是什么？

当消费者连接到接收终端，唯一命名的交换和队列创建如： bus-{MachineName}-{ApplicationName}-{Identifier} 这是什么队列/交换的目的是什么？有没有任何文件详细说明这一点？

0热度

2回答

使用Autofac在Masstransit中注册一个IConsumer <T>

我有2个系统，一个用于发布消息和其他消耗它们。两者都使用Masstransit（使用RabbitMQ），并使用ASP.Net web api 2和OWIN（以及Autofac作为IoC容器）来实现。一切工作正常，如果我的消费者没有依赖关系，，但是当我注入一个依赖到我的消费者时，消费方法永远不会执行（在初始化期间没有错误抛出）。这是相关出版商代码： //Startup.cs public cl

0热度

1回答

健康检查MassTransit和Rabbitmq

我正计划在ASP .net核心应用程序中实施健康检查中间件。例如，要检查数据库是否健康，我打开并关闭数据库连接。同样，检查MassTransit是否健康的最佳方法是什么（即它可以连接并发送/发布消息而没有问题）？

0热度

1回答

有没有办法从MassTransit获取原始消息？

我有一个消费者的泛型参数IEvent。此类型是所有消息的基本接口，并且IEvent的子接口具有其他一些属性。我希望能够访问具有嵌套类型的所有属性的原始消息，而不仅仅是IEvent范围。这些属性可以通过RMQ管理仪表板看到，我认为应该有办法将它们排除出去。

0热度

1回答

混淆Masstransit ReceiveFrom方法和消费者行为

我想创建一个队列与RabbitMq在哪里我会发送一些消息在一边，并在另一个应用程序接收。我'与下面的代码这样做： return ServiceBusFactory.New(x => { var uriString = string.Format(@"rabbitmq://{0}/{1}/{2}?prefetch={3}", host, virtualHost, queue

-1热度

1回答

如何与使用Rebus的MassTransit创建的Azure Service Bus主题互操作？

我有一个现有的系统，通过MassTransit发布消息到一些Azure服务总线主题名为CompanyName.SystemName.Messages.SomethingGotUpdated。如何使用Rebus配置新系统作为该特定主题的订阅者，然后将所有消息发送到相应的IHandleMessages<SomethingGotUpdated>处理程序？我查看了文档，但无法真正弄清楚如何完成此操作。任

1热度

1回答

如何在Masstransit/RabbitMQ中组织队列？

我想知道消费消息的最佳实践。我已经阅读了MassTransit文档，并且正在寻找这方面的内容，但是我没有得出任何结论。我有一个api（托管公交车实例），正在发布消息。这些消息是多种多样的，因为这个API不是微服务（购买，销售等的消息）。如何组织我的消费者/队列？一个队列类型的过程？例如，一个用于购买，另一个用于销售，这个解决方案可能涉及许多流程，我不确定它是否是一个好的解决方案。如果我想购买

0热度

2回答

masstransit在传奇中推迟回复

我正在调查在公共交通中使用传奇来编排跨多项服务的活动。这个传奇的生命是短暂的 - 如果一切顺利，不到2秒。对于我的使用情况下，我想用请求/响应方式，从而使客户端请求命令，佐贺处理该命令，通过一些状态变化都按收到的消息，并最终响应第一命令发起了传奇，在这一点上客户收到回应，并可以显示传奇的结果。从我所看到的情况来看，在这一点上，上下文不再意识到最初的请求。我如何回复以这种方式收到的消息？在处理第

0热度

2回答

如何动态设置预取计数RabbitMq

可以动态设置预取计数参数吗？这里是我想达到的。我有队列用户的服务。我有观察服务器资源（如处理器使用情况，RAM等）的机制。当这些资源用得很多时，这种机制会向服务发送通知。所以，当这个通知来了，我喜欢停止从队列中检索消息。它可以通过从队列中取消订阅来完成，但效率会很高？此通知到来时，可以动态设置预取计数为1吗？如果没有，如何实现这种事情？我使用C＃和MasstTransit作为服务总线。