subscribe.php 358 B

1234567891011121314151617181920212223242526
  1. <?php
  2. require("./phpMQTT.php");
  3. $mqtt = new phpMQTT("localhost", 1883, "musikar");
  4. if(!$mqtt->connect()){
  5. exit(1);
  6. }
  7. $topics['hello'] = array("qos"=>0, "function"=>"procmsg");
  8. $mqtt->subscribe($topics,0);
  9. while($mqtt->proc()){
  10. }
  11. $mqtt->close();
  12. function procmsg($topic,$msg){
  13. echo "Msg Recieved: ".date("r")."\nTopic:{$topic}\n$msg\n";
  14. }
  15. ?>