protected function connectZmq()
    {
        $context = new ZMQContext();
        $this->socket = $context->getSocket(ZMQ::SOCKET_PUSH, self::SOCKET_PULL_ID . '.' . App::environment());
        $this->socket->connect('tcp://localhost:' . config('twostream.push.port'));
        
        return $this->socket;
    }