Search the Community
Showing results for tags 'mqtt'.
Found 1 result
-
Hi, The code below fails with error and I just cannot understand what's causing the issue. So, I really appreciate some help. TIA <?php require("phpMQTT.php"); $server = "server.com"; // change if necessary $port = 1883; // change if necessary $username = ""; // set your username $password = ""; // set your password $client_id = "MqttClient-client"; // make sure this is unique for connecting to sever - you could use uniqid() $mqtt = new phpMQTT($server, $port, $client_id); if(!$mqtt->connect(true,NULL,$username,$password)){ echo "Connection error!"; exit(1); } else { echo "Connected!"; echo "<br>"; } //currently subscribed topics $topics["casa/rp2/soil/moist"] = array("qos"=>1, "function"=>"procmsg"); $mqtt->subscribe($topics, 1); while($mqtt->proc()){ } $mqtt->close(); function procmsg($topic,$msg){ echo "Msg Recieved: $msg"; } and lib's line 289 is
