Fix

sergejey · Jan 3, 2019 · 59aa612 · 59aa612
1 parent b773160
commit 59aa612
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 5 deletions.
diff --git a/modules/mqtt/mqtt.class.php b/modules/mqtt/mqtt.class.php
@@ -329,7 +329,7 @@ function processMessage($path, $value) {
        setGlobal($rec['LINKED_OBJECT'].'.'.$rec['LINKED_PROPERTY'], $value, array('mqtt'=>'0'));
      }
      if ($rec['LINKED_OBJECT'] && $cmd_rec['LINKED_METHOD']) {
-       callMethod($rec['LINKED_OBJECT'] . '.' . $rec['LINKED_METHOD'], $rec['VALUE']);
+       callMethodSafe($rec['LINKED_OBJECT'] . '.' . $rec['LINKED_METHOD'], $rec['VALUE']);
      }
 
    }

diff --git a/scripts/cycle_mqtt.php b/scripts/cycle_mqtt.php
@@ -117,10 +117,10 @@
  * @return void
  */
 function procmsg($topic, $msg) {
-    $url = BASE_URL . '/ajax/mqtt.html?op=process&topic='.urlencode($topic)."&msg=".urlencode($msg);
-    getURLBackground($url);
-    //global $mqtt;
-    //$mqtt->processMessage($topic, $msg);
+    //$url = BASE_URL . '/ajax/mqtt.html?op=process&topic='.urlencode($topic)."&msg=".urlencode($msg);
+    //getURLBackground($url);
+    global $mqtt;
+    $mqtt->processMessage($topic, $msg);
     //echo date("Y-m-d H:i:s") . " Topic:{$topic} $msg\n";
 }