C# Service Bus несколько слушателей получают одно и то же сообщение (BrokeredMessage)

Question

Раньше я использовал RabbitMQ в качестве платформы обмена сообщениями, и у меня никогда не было никаких проблем с этим - к сожалению, мы недавно перевели нашу инфраструктуру на Azure, t обеспечивают серверы RabbitMQ, поэтому я подумал о попытке расширения служебной шины.

У меня есть один писатель и несколько читателей. В настоящее время каждый читатель будет читать другое сообщение (конкурирующий шаблон сообщения - например, хороший для балансировки нагрузки).

Что я хочу, это то, что все читатели получают то же сообщение и обрабатывают его сами.

Читатель (ы):

string connectionKey = "...."; 
     this.client = QueueClient.CreateFromConnectionString(connectionKey, "dev"); 
     this.client.OnMessage((message) => 
     { 
      try 
      { 
       Console.WriteLine("Message received: " + message.GetBody<string>()); 
       Console.WriteLine("Message ID: " + message.MessageId); 
       // message.Complete(); 
      } 
      catch (Exception e) 
      { 
       Console.WriteLine("Exception " + e.Message); 
      } 
     }); 

Автор:

Console.WriteLine("Sending message " + message); 
     BrokeredMessage msg = new BrokeredMessage(message); 
     this.client.Send(msg); 

Я искал решение в течение двух часов и не смогли найти ничего. В RabbitMQ это будет поведение по умолчанию.

Image showing pattern of what I have vs. what I need

Answer 1

Azure Service Bus поддерживает несколько парадигм, один из которых называется "Темы":

How to use Service Bus topics and subscriptions

В отличие от Service Bus очереди, в которой каждое сообщение обрабатывается один потребитель, темы и подписки предоставляют форму общения «один ко многим», используя шаблон публикации/подписки.

Ссылка выше демонстрирует основные темы концепций, а также образцы кода.