private function bootZmqConnection()
    {
        $this->info(sprintf('Starting ZMQ listener on: %s:%s', config('ratchet.zmq.host'), config('ratchet.zmq.port')));

        $context = new ZMQContext($this->getEventLoop());
        $socket = $context->getSocket(config('ratchet.zmq.method', \ZMQ::SOCKET_PULL));
        $socket->bind(sprintf('tcp://%s:%d', config('ratchet.zmq.host', '127.0.0.1'), config('ratchet.zmq.port', 5555)));

        $socket->on('messages', function ($messages) {
            $this->ratchetServer->onEntry($messages);
        });

        $socket->on('message', function ($message) {
            $this->ratchetServer->onEntry($message);
        });
    }
private function bootZmqConnection()
    {
        $this->info(sprintf('Starting ZMQ listener on: %s:%s', config('ratchet.zmq.host'), config('ratchet.zmq.port')));

        $context = new ZMQContext($this->getEventLoop());
        $socket = $context->getSocket(config('ratchet.zmq.method', \ZMQ::SOCKET_PULL));
        $socket->bind(sprintf('tcp://%s:%d', config('ratchet.zmq.host', '127.0.0.1'), config('ratchet.zmq.port', 5555)));

        $socket->on('messages', function ($messages) {
            $this->ratchetServer->onEntry($messages);
        });

        $socket->on('message', function ($message) {
            $this->ratchetServer->onEntry($message);
        });
    }
private function bootZmqConnection ( ) { $ this -> info ( sprintf ( 'Starting ZMQ listener on: %s:%s' , config ( 'ratchet.zmq.host' ) , config ( 'ratchet.zmq.port' ) ) ) ; $ context = new ZMQContext ( $ this -> getEventLoop ( ) ) ; $ socket = $ context -> getSocket ( config ( 'ratchet.zmq.method' , \ ZMQ :: SOCKET_PULL ) ) ; $ socket -> bind ( sprintf ( 'tcp://%s:%d' , config ( 'ratchet.zmq.host' , '127.0.0.1' ) , config ( 'ratchet.zmq.port' , 5555 ) ) ) ; $ socket -> on ( 'messages' , function ( $ messages ) { $ this -> ratchetServer -> onEntry ( $ messages ) ; } ) ; $ socket -> on ( 'message' , function ( $ message ) { $ this -> ratchetServer -> onEntry ( $ message ) ; } ) ; }
Boot a ZMQ listener and let the Ratchet server handle its events.
Boot a ZMQ listener and let the Ratchet server handle its events .