protected function createWorkerHandlerStream(Socket $socket)
    {
        $socket->setId('manager');
        $this->getPoller()->add($socket, ZMQ::POLL_IN);

        $that = $this;
        $this->workerHandlerStream = $socket->getStream();
        $this->workerHandlerStream->addListener(StreamInterface::MESSAGE, function (MessageEvent $event) use ($that) {
            if (null === $event->getProtocolMessage()) {
                $message = $event->getMessage();

                $that->getLogger()->error('Non-protocol message detected in worker-handler stream: '.$message);

                return;
            }

            $that->onWorkerHandlerMessage($event->getProtocolMessage());
        });
    }