protected function createReplySocket()
    {
        $replyContext = new \ZMQContext;
        $this->replySocket = $replyContext->getSocket(\ZMQ::SOCKET_REQ);
        $this->replySocket->connect($this->config['sockets']['worker_reply']);
    }