Несколько прослушивателей служебной шины C# получают одно и то же сообщение ( BrokeredMessage ). ⇐ C#

[Гость]

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

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

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

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

Код: Выделить всё

string connectionKey = "....";
this.client = QueueClient.CreateFromConnectionString(connectionKey, "dev");
this.client.OnMessage((message) =>
{
try
{
Console.WriteLine("Message received: " + message.GetBody());
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 это будет поведение по умолчанию.

Изображение, показывающее соотношение того, что у меня есть, и того, что мне нужно

Подробнее здесь: https://stackoverflow.com/questions/373 ... brokeredme