2016-12-07 269 views
0

時IClusterHostSelectionStrategy不工作我添加了新的RabbitMQ服務器&配置我的出版商連接字符串與EasyNETQ集羣 - 發佈消息

"host=PC1:5672,PC2:5672" 

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

當我我真的使用bus.Publish(msg)

當我發佈消息發佈時,消息只發送給PC 1。 我怎樣才能確保消息將隨機發送給兩者。

回答

0

實例僅在實例化時創建1個連接,但隨機選擇該主機。

如果你真的想發送到隨機主機,你可以創建2個總線實例連接到2個不同的主機,並在你發佈之前隨機選擇其中一個。