gistfile1.aw

<?php

class liveNode {

	private $host = '127.0.0.1';
	private $port = '5566';
	static private $queue;
	
	private $timeout = 5000; // milliseconds
	
	public function __construct() {
		if (!isset(self::$queue)) {
			try {
				self::$queue = new ZMQSocket(new ZMQContext(), ZMQ::SOCKET_REQ, "live");
				self::$queue->connect('tcp://'.$this->host.':'.$this->port);
				$poll = new ZMQPoll();
				$id = $poll->add(self::$queue, ZMQ::POLL_IN);
				$readable = $writeable = array();
				$events = $poll->poll($readable, $writeable, $this->timeout);
			} catch(ZMQPollException $e) {
				throw new expection("problem with liveNode zmq connection: ".$e->getMessage());
				return false;
			}
		}
		return true;
	}
	
	public function send($room, $emit, $data) {
		self::$queue->send(json_encode(array("room" => $room, "emit" => $emit, "data" => $data)));
		self::$queue->recv();
	}
	
}

?>