2012-08-29 166 views
0

是否可以使用ZeroMQExtensions創建具有多個傳出(傳入)連接的套接字?Akka ZeroMQExtension使用一個zeromq套接字創建多個連接

有關多個連接的更多信息in ZeroMQ guide

upd: 我無法看到具有ZeroMQExtensions的等值樣本。在0MQExtensions documnetation我發現:

newPubSocket(socketParameters: Array[SocketOption]): ActorRef 

Java API的工廠方法來創建一個表示ZeroMQ發佈插座的演員。您可以根據需要傳入儘可能多的配置選項,並且配置選項的順序無關緊要它們在類型上匹配並且第一個找到了勝利。

PS:我不知道scala,只是開始閱讀akka文檔來理解我需要aka或不。

+0

發生了什麼事時,你試過嗎? –

+0

請參閱更新以瞭解我的問題 – komelgman

回答

0

我找到解決方案(這是不直觀,但工程):

ActorRef subSocket = ZeroMQExtension.get(getContext().system()) 
      .newSubSocket(null, new Listener(getSelf()), new Subscribe("health")); 

    @Override 
    public void preStart() { 
     super.preStart(); 

     subSocket.tell(new Connect("tcp://127.0.0.1:1237")); 
     subSocket.tell(new Connect("tcp://127.0.0.1:1238")); 
    } 
+0

對我來說相當直觀(將連接消息發送到要連接的目的地) –

+0

感謝Viktor,很好的框架。對演員中的新手來說並不直觀 – komelgman

+0

當你是新手時,沒有什麼直觀的:-)這就是爲什麼學習是如此的有益! –

相關問題