Akka ZeroMQExtension使用一个zeromq套接字创建多个连接

Question

是否可以使用ZeroMQExtensions创建具有多个传出（传入）连接的套接字？

有关多个连接的更多信息in ZeroMQ guide。

upd： 我无法看到具有ZeroMQExtensions的等值样本。在0MQExtensions documnetation我发现：

newPubSocket(socketParameters: Array[SocketOption]): ActorRef 

Java API的工厂方法来创建一个表示ZeroMQ发布插座的演员。您可以根据需要传入尽可能多的配置选项，并且配置选项的顺序无关紧要它们在类型上匹配并且第一个找到了胜利。

PS：我不知道scala，只是开始阅读akka文档来理解我需要aka或不。

Answer 1

我找到解决方案（这是不直观，但工程）：

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")); 
    }