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;
    }
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;
    }
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 ; }
Connect to socket.

@return \ZMQSocket
Connect to socket .