Untitled

<html>
<form action="test.php" method="post">
<INPUT name="btn_submit" TYPE="submit" VALUE="ON">
<INPUT name="btn_submit" TYPE="submit" VALUE="OFF">

<INPUT name="btn_submit" TYPE="submit" VALUE="REQUERY">

</form>
</body>
</html>

<?php
require("phpMQTT.php");
$username="user";
$password="pass";
$mqtt = new phpMQTT("m20.cloudmqtt.com", 12213,"phpMQTT Pub Examplexxx"); //Change client name to something unique


function subread(){
echo "subscribing<br>";

if(!$mqtt->connect(true, NULL, $username, $password)) { exit(1);}
$topics['#'] = array("qos"=>0, "function"=>"procmsg");
$mqtt->subscribe($topics,0);
$start_time = time(); $done = 0;
while (!$done && !hasTimedout() && $mqtt->proc()) { } $mqtt->close();
}


function procmsg($topic,$msg) { global $done; $done = 0; echo "Message Received: ".date("r")."<br>"."nTopic:{$topic}n$msgn";}
function hasTimedout() {global $start_time; return (time() - $start_time > 5); }


switch ($_REQUEST['btn_submit']){
case "ON":
subread();

if($mqtt->connect(true, NULL, $username, $password)){
    $mqtt->publish("cmnd/JM/POWER","ON",0);
$mqtt->close();
}
break;
case "OFF":
if($mqtt->connect(true, NULL, $username, $password)){
    $mqtt->publish("cmnd/JM/POWER","OFF",0);
$mqtt->close();
}
break;
case "REQUERY":
    subread();
break;
}

?>