diff --git a/examples/.testOnpublish.php.un~ b/examples/.testOnpublish.php.un~ deleted file mode 100644 index ede5470..0000000 Binary files a/examples/.testOnpublish.php.un~ and /dev/null differ diff --git a/examples/testOnpublish.php~ b/examples/testOnpublish.php~ deleted file mode 100644 index fedce36..0000000 --- a/examples/testOnpublish.php~ +++ /dev/null @@ -1,68 +0,0 @@ -id = $mid; - self::$publish[$mid] = $msg; - } - - public static function confirm($mid) { - if(array_key_exists($mid, self::$publish)) { - self::$publish[$mid]->state = true; - } - } - - public static function addReceive($msg) { - $msg = Message::factory($msg, true); - self::$receive[$msg->id] = $msg; - } -} - -class Message { - public $id; - public $state = false; - public $msg; - public static function factory(Mosquitto\Message $msg, $state = false) { - $message = new Message(); - $message->state = $state; - $message->msg = $msg; - $message->id = $msg->mid; - return $message; - } -} -$client = new Mosquitto\Client('client.terminal.onpublish', false); - -$client->onMessage(function($msg) { - print_r(array('receive', $msg)); - MQ::addReceive($msg); -}); - -$client->onPublish(function($mid) { - MQ::confirm($mid); - print_r(array('comfirm publish', MQ::$publish[$mid])); -}); -$client->onConnect(function($rc, $msg) { - print_r(array('rc' => $rc, 'message' => $msg)); - $client->subscribe('/test/onpublish', 1); - $msg = Message::factory(new Mosquitto\Message()); - $msg->msg->topic = '/test/onpublish'; - $msg->msg->payload = 'hello from on publish'; - $msg->qos = 1; - $mid = $client->publish($msg->msg->topic, $msg->msg->payload, $msg->msg->qos); - MQ::addPublish($mid, $msg); -}); - -$client->connect('localhost', 1883, 60); - -sleep(1); - - -$client->subscribe('/test/onpublish', 1); -$msg = Message::factory(new Mosquitto\Message()); -$msg->msg->topic = '/test/onpublish'; -$msg->msg->payload = 'hello from on publish'; -$msg->qos = 1; -$mid = $client->publish($msg->msg->topic, $msg->msg->payload, $msg->msg->qos); -MQ::addPublish($mid, $msg); -