2016-12-07 4 views
0

Ich habe neue RabbitMQ Server & meiner Publisher Verbindungen String konfiguriert mitEasyNETQ Cluster - IClusterHostSelectionStrategy funktioniert nicht, wenn die Nachricht zu veröffentlichen

"host=PC1:5672,PC2:5672" 

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

Wenn ich I`m bus.Publish(msg) mit veröffentlichen

Wenn ich Nachrichten veröffentlichen, die Meldungen werden nur an PC 1 gesendet. Wie kann ich sicherstellen, dass Nachrichten an beide nach dem Zufallsprinzip gesendet werden.

Antwort

0

Die Instanz erstellt nur eine Verbindung, wenn Sie sie instanziieren, wählt diesen Host jedoch nach dem Zufallsprinzip aus.

Wenn Sie wirklich an zufällige Hosts senden möchten, können Sie zwei Businstanzen erstellen, die mit den zwei verschiedenen Hosts verbunden sind, und Sie können eine davon zufällig auswählen, bevor Sie veröffentlichen.

Verwandte Themen