masstransit

0热度

1回答

我正在使用Masstransit + RabbitMQ。我的一位消费者实现重试策略，并且我想知道是否有任何方法可以在消息进入错误队列时获取消息的重试次数？另外我想知道MT如何计数重试，因为我没有在使用RabbitMq服务器的消息头中找不到任何相关信息。谢谢。

0热度

1回答

MassTransit生产者需要60秒时间消耗事件

我有2个项目：一个MassTransit（Topshelf Windows服务）叫Service.Endpoints 一个控制台应用程序客户端试图沟通与它叫做TestConsole。的总体要求是如下： TestConsole发送SolveProblemCommand Service.Endpoints消耗命令并发布ProblemSolvedEvent TestConsole消耗该事件。问题：

0热度

1回答

MassTransit和MaxConcurrentCalls的行为与预期不符？

我使用MassTransit作为我的消息框架，在Azure Service Bus上运行。我正在WebJob中运行MassTransit（虽然我不认为这很重要）现在我试图让MassTransit同时处理多个消息，因为我正在处理单独的消息需要一段时间来处理。所以为了加速性能，我不希望每个消息都被逐一处理。我试着设置MaxConcurrentCalls为例如30，但似乎没有这样做。消息仍然由我的消

0热度

1回答

如何使用MassTransit由多个消费者订阅一个队列？

我使用Azure的服务总线运输的MassTransit我试图发送消息（命令）排队： var sendEndpoint = await busControl.GetSendEndpoint(sericeUri); sendEndpoint.Send<ISimpleRequest>(new SimpleRequest(customerId)); 我也试图用两个用户连接到这个队列： var _bu

1热度

1回答

MassTransit发布到特定队列

我已经成功地将2.x的MassTransit应用程序更新到3.x，并切换到我的传输RabbitMQ。我这样做是为了让一对多消息传递正常运行，之前的开发人员认为它可以与MSMQ协同工作，但是我发现它不起作用，通过阅读我需要使用3.x和RabbitMQ的文档变得清楚。我的应用程序在服务器上运行一个网站的多个实例，每个实例针对特定的客户群。我希望每个实例都发布到特定队列，以便数据仅可用于特定实例的后端

0热度

1回答

如果消费者关机，会发生什么？（MassTransit）

我使用MassTransit编写消费者并使用Azure服务总线作为传输。 public async Task Consume(ConsumeContext<ISimpleRequest> context) { try { _log.InfoFormat("Strated working on {0}", context.Message.CustomerId);

0热度

1回答

修改消费中间件的消息标题

消息消息过程中有什么方法可以修改消息的中间件标题吗？正如我所看到的ConsumeContext上的Headers接口不提供任何方式来设置标题，有没有其他方式来实现呢？谢谢！

1热度

1回答

如何配置消耗以使用不同的消息类型？（MassTransit）

我正在使用MassTransit和Azure服务总线作为传输。我创建了实现IAlert的IAlert和IAlertExt。我试图发布两条消息： busControl.Publish<IAlert>(new Alert(customerId)); busControl.Publish<IAlertExt>(new AlertExt(customerId)); 而写的消费者来处理消息： pub

1热度

1回答

什么是Azure服务总线中的队列生存期？

我使用MassTransit和Azure Service Bus作为传输创建队列。我不是在问消息的一生。如果没有一个订阅者不订阅这个队列，我需要知道队列何时被删除？

0热度

1回答

检索发布者在用户连接后发送的邮件（masstransit）

我创建了一个使用MassTransit和Azure服务总线作为传输工具的应用程序。发布，发送，检索事件和命令 - 这一切都很好。但是现在我想创建订阅者来检索发布者在用户连接后发送的消息。怎么做？我不想在连接之前获取发布商发送的所有消息。