Azure 上的公共交通 MaxConcurrentCalls 设置被忽略

Question

我在 Azure 上的 MassTransit 和在总线上配置 MaxConcurrentCalls 时遇到问题。我有一个要求一次执行 1 条消息的进程，但我无法使用总线配置实现这一点。例如，在总线配置期间，我设置了以下

busConfigurator.MaxConcurrentCalls = 1;
busConfigurator.PrefetchCount = 0;

注册消费者后，我立即向端点发送 3 条消息，并立即创建并开始处理 3 个消费者实例。下面是来自 Log4Net 的日志片段。

我想知道有没有其他人遇到过这个问题，他们是如何解决的，或者知道我可能做错了什么。从下面的日志中可以看出，这些消息会立即开始执行，即使每条消息都需要大约 10-15 秒的时间来处理。

[2017-02-03 16:48:18,410]   [DEBUG] [13]    [svcbus.Consumers.SellerPageConsumer]   [Consume]   []  [Loading page https://....... ]     
[2017-02-03 16:48:18,410]   [DEBUG] [14]    [svcbus.Consumers.SellerPageConsumer]   [Consume]   []  [Loading page https://....... ]     
[2017-02-03 16:48:18,420]   [DEBUG] [23]    [svcbus.Consumers.SellerPageConsumer]   [Consume]   []  [Loading page https://....... ]

Answer 1

更新
我查看了 Azure 配置属性。
配置接收端点时，您可以在那里设置 MaxConcurrentCalls 和 PrefechCount。
这个应该有效

configurator.ReceiveEndpoint(host,"QueueName", re =>
{
    re.MaxConcurrentCalls = 1;
    re.PrefetchCount = 1;
    //configure consumers & other stuff here ...
});

旧答案
不是 azure 特定的，但是在 RabbitMQ 上，我通过在配置器对象上调用 UseConcurrencyLimit 来设置最大并发消费者例如

bus = MassTransit.Bus.Factory.CreateUsingRabbitMq(configurator =>
{
    configurator.UseConcurrencyLimit(options.MaxConcurrentConsumers);
    . . .
}

Azure 配置器上是否有类似的东西？

Azure 上的公共交通 MaxConcurrentCalls 设置被忽略

Masstransit MaxConcurrentCalls setting on Azure being ignored

masstransit

azure