*/
class ReactSocketPusher extends Pusher
{
public function push($message)
{
$fp = stream_socket_client(
'tcp://' . WEBSOCKET_PULLER_BIND_ADDR
. ':' . WEBSOCKET_PULLER_PORT, $errno, $errstr, 30);
if ($fp)
{
fwrite($fp, json_encode($message));
fclose($fp);
}
}
}
WebSVN
- freenet-router
- Blame
- Rev 2
- /trunk/freenet-router/var/www/freenet-router/Framework/Libraries/MessageBus/ReactSocketPusher.php
freenet-router |
Subversion Repositories: |
[/] [trunk/] [freenet-router/] [var/] [www/] [freenet-router/] [Framework/] [Libraries/] [MessageBus/] [ReactSocketPusher.php] - Blame information for rev 2
Powered by WebSVN 2.2.1