У меня два хозяина - А и Б
Я использую следующий фрагмент кода для настройки служебной шины на хосте A.
host.BusConfiguration(c => c.Threads(1).Retries(1)
.Bus(endpointA.AbsoluteUri, "name", true)
.Receive(typeof(MyMessage).Namespace, hostB.Endpoint.AbsoluteUri, true)
Это конфигурирует хост для создания шины, которая прослушивает адрес e ndpointA.AbsoluteUri
и записывает сообщения из пространства имен [typeof(MyMessage).Namespace]
в очередь, расположенную в hostB.Endpoint.AbsoluteUri
, правильно?
Я использую тот же код для настройки, если шина в хосте B (с использованием hostB, где стоит hostA)
Я не могу настроить два хоста для взаимной отправки и получения сообщений друг другу. Только один из них (A) может отправлять сообщения, полученные B. Когда B отправляет сообщение, сообщение просто помещается в очередь и не используется A. В чем может быть причина?