*/ class ZMQPusher extends Pusher { public function push($message) { $context = new \ZMQContext(); $socket = $context->getSocket(\ZMQ::SOCKET_PUSH, 'ZMQ Pusher'); $socket->connect("tcp://" . WEBSOCKET_PULLER_BIND_ADDR . ":" . WEBSOCKET_PULLER_PORT); $socket->send(json_encode($message)); } } WebSVN - freenet-router - Blame - Rev 2 - /trunk/freenet-router/var/www/freenet-router/Framework/Libraries/MessageBus/ZMQPusher.php

freenet-router

Subversion Repositories:

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

Line No.	Rev	Author	Line