2016-12-07 3 views
0

를 게시 할 때 IClusterHostSelectionStrategy가 작동하지 나는 내가 난`이EasyNETQ 클러스터 - 메시지

내가 메시지를 게시 bus.Publish(msg)를 사용하여 게시 할 때 새 RabbitMQ 서버 &이

"host=PC1:5672,PC2:5672" 

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

으로 내 게시자 연결 문자열을 구성 추가 메시지가 PC 1에만 전송됩니다. 어떻게 메시지를 무작위로 보낼 것인지 확인할 수 있습니다.

답변

0

인스턴스는 인스턴스화 할 때 단 하나의 연결 만 생성하지만 임의로 해당 호스트를 선택합니다.

무작위 호스트로 보내려면 2 개의 다른 호스트에 연결하는 2 개의 버스 인스턴스를 만들고 게시하기 전에 임의로 선택하십시오.