Кластер EasyNETQ - IClusterHostSelectionStrategy не работает при публикации сообщения

Я добавил новый сервер RabbitMQ и настроил строку подключения к издателю с помощью

"host=PC1:5672,PC2:5672"

var bus = RabbitHutch.CreateBus(connectionString, x => x.Register<IClusterHostSelectionStrategy<ConnectionFactoryInfo>, RandomClusterHostSelectionStrategy<ConnectionFactoryInfo>>());

Когда я публикую, я использую bus.Publish(msg)

Когда я публикую сообщения, сообщения отправляются только на ПК 1. Как я могу убедиться, что сообщения будут отправляться обоим случайным образом.


rabbitmq easynetq
person liormk1    schedule 07.12.2016    source источник

Ответы (1)


arrow_upward
0
arrow_downward

Экземпляр создает только 1 соединение, когда вы его создаете, но выбирает этот хост случайным образом.

Если вы действительно хотите отправлять на случайные хосты, вы можете создать 2 экземпляра шины, подключающихся к 2 разным хостам, и выбрать один из них случайным образом перед публикацией.

person Wiebe Tijsma    schedule 08.12.2016