protected function createWorkerReplySocket()
    {
        /** @var Context|\ZMQContext $workerReplyContext */
        $workerReplyContext = new Context($this->loop);
        $this->workerReplySocket = $workerReplyContext->getSocket(\ZMQ::SOCKET_REP);
        $this->workerReplySocket->bind($this->config['sockets']['worker_reply']);
        $this->workerReplySocket->on('message', [$this, 'onWorkerReplyMessage']);
    }
protected function createWorkerReplySocket()
    {
        /** @var Context|\ZMQContext $workerReplyContext */
        $workerReplyContext = new Context($this->loop);
        $this->workerReplySocket = $workerReplyContext->getSocket(\ZMQ::SOCKET_REP);
        $this->workerReplySocket->bind($this->config['sockets']['worker_reply']);
        $this->workerReplySocket->on('message', [$this, 'onWorkerReplyMessage']);
    }
protected function createWorkerReplySocket ( ) { /** @var Context|\ZMQContext $workerReplyContext */ $ workerReplyContext = new Context ( $ this -> loop ) ; $ this -> workerReplySocket = $ workerReplyContext -> getSocket ( \ ZMQ :: SOCKET_REP ) ; $ this -> workerReplySocket -> bind ( $ this -> config [ 'sockets' ] [ 'worker_reply' ] ) ; $ this -> workerReplySocket -> on ( 'message' , [ $ this , 'onWorkerReplyMessage' ] ) ; }
Creates worker-reply-socket and assigns listener.
Creates worker - reply - socket and assigns listener .