Azure WebJob параллелизм при использовании ServiceBusTrigger

Question

Я использовал очереди хранения Azure для подачи WebJob, используя атрибут QueueTrigger. Настроить мой QueueTrigger чтобы из очереди ряда элементов для параллельной обработки, например:

public static void Main() 
{ 
    JobHostConfiguration config = new JobHostConfiguration(); 
    config.NameResolver = new QueueNameResolver(); 

    config.Queues.NewBatchThreshold = 10; 

    JobHost host = new JobHost(config); 
    host.RunAndBlock(); 
} 

public static void ExecuteStorageQueueItem([QueueTrigger("%AzureQueueName%")] CloudQueueMessage message, TextWriter logger) 
{ 
    ProcessRequest(message.AsString, logger); 
} 

Я предпочел бы использовать Service Bus. Параметр MaxConcurrentCalls на ServiceBusConfiguration допускает одно и то же автоматическое параллельное выполнение? Например:

public static void Main() 
{ 

    JobHostConfiguration config = new JobHostConfiguration(); 
    config.NameResolver = new QueueNameResolver(); 

    ServiceBusConfiguration serviceBusConfig = new ServiceBusConfiguration(); 
    serviceBusConfig.MessageOptions.MaxConcurrentCalls = 10; 
    config.UseServiceBus(serviceBusConfig); 

    JobHost host = new JobHost(config); 
    host.RunAndBlock(); 
} 

public static void ExecuteServiceBusItem([ServiceBusTrigger("%ServiceBusQueueName%")] BrokeredMessage message, TextWriter logger) 
{ 
    ProcessRequest(message.GetBody<string>(), logger);    
} 

Я не уверен, имеет ли MaxConcurrentCalls, что я думаю, что это делает!

Answer 1

По существу да, MaxConcurrentCalls определяет количество потоков, используемых клиентом для обработки очереди.

Когда QueueClient.OnMessage метод называется it starts a message pump на петле infinte, которая постоянно опроса. OnMessageOptions.MaxConcurrentCall устанавливает number of concurrent calls to the callback the message pump should initiate.

Больше предыстория: Introducing the Event-Driven Message Programming Model for the Windows Azure Service Bus