*/ class ZMQPuller extends WebsocketPuller { protected $server; public function __construct(LoopInterface $loop, MessageBus $msgBus) { $context = new Context($loop); $this->server = $context->getSocket(\ZMQ::SOCKET_PULL); $this->server->on('message', array($msgBus, 'onNotify')); } public function listen($ip, $port) { $this->server->bind('tcp://'.$ip.':'.$port); } } WebSVN - freenet-router - Blame - Rev 2 - /trunk/freenet-router/var/www/freenet-router/Framework/Libraries/MessageBus/ZMQPuller.php

freenet-router

Subversion Repositories:

[/] [trunk/] [freenet-router/] [var/] [www/] [freenet-router/] [Framework/] [Libraries/] [MessageBus/] [ZMQPuller.php] - Blame information for rev 2

Line No.	Rev	Author	Line