被忽略的Azure上的Mas搁浅MaxConcurrentCalls设置

Question

我对Azure上的MassTransit和总线上的MaxConcurrentCalls有一个问题。我有一个进程要求一次执行一条消息，但是我不能使用总线配置来实现这一点。例如，在总线配置期间，我设置了以下内容

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 ...
});

旧答案

不是特定于天蓝色，但在RabbitMQ上，我通过调用配置器对象上的UseConcurrencyLimit来设置最大并发使用者。

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

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