Debug

(cherry picked from commit b789d72128)

app/Libs/MQTTClient.php

@@ -218,6 +218,8 @@ class MQTTClient {
      * @return boolean Returns false if connection failed
      */
     public function sendConnect($clientId, $cleanSession=false, $keepAlive=10, $timeout=5000) {
+
+        var_dump('serverAddress', $this->serverAddress);
         if (!$this->serverAddress) return false;
 
         // Basic validation of clientid
@@ -390,8 +392,9 @@ class MQTTClient {
      * @return boolean
      */
     public function sendPublish($topic, $message, $qos = self::MQTT_QOS1, $retain = 0) {
+        var_dump('connect:', $this->isConnected());
         if(!$this->isConnected()) return false;
-
+var_dump('sendpublish', [$topic, $message, $qos]);
         if($qos!=self::MQTT_QOS0 && $qos!=self::MQTT_QOS1 && $qos!=self::MQTT_QOS2) return false;
 
         $packetId = $this->getNextPacketId();
@@ -405,6 +408,7 @@ class MQTTClient {
         $dupFlag = 0;
         $header = $this->createHeader(self::MQTT_PUBLISH + ($dupFlag<<3) + ($qos<<1) + $retain, $payload);
         $this->debugMessage('Sending PUBLISH');
+        var_dump('sendpublish-$payload', $header.$payload);
         $this->send($header . $payload);
 
         if($qos == self::MQTT_QOS1) {

app/Service/MqttSpeakerService.php

@@ -76,7 +76,7 @@ class MqttSpeakerService implements MqttServiceInterface
 
         $curClientId OR $curClientId = (string)rand(1,999999999);
         $success = $client->sendConnect($curClientId);
-
+        var_dump('$success', $success);
         if ($success) {
             $client->sendPublish($topic, json_encode($msgArr), MQTTClient::MQTT_QOS2);
             $client->sendDisconnect();