V1.2.5

1、修改了MQTTBase

module/mqtt/MQTTBase.cpp

@@ -24,6 +24,7 @@ MQTTBase::MQTTBase(QObject* parent) : QObject(parent)
     connect(&m_client,SIGNAL(subscribed(QString,quint8)),this,SLOT(do_subscribed(QString, quint8)));
 
     connect(&m_client,SIGNAL(received(QMQTT::Message)),this,SLOT(do_received(QMQTT::Message)));
+    connect(&m_client, &QMQTT::Client::received, this, &MQTTBase::signal_recvMessage);
 }
 
 /* 设置地址 */

module/mqtt/MQTTBase.h

@@ -34,7 +34,9 @@ public:
     
 signals:
     /* 接收到消息，对消息进行了转发 */
-    void signal_recvMessage(const QString& message);
+    // void signal_recvMessage(const QString& message);
+    /* 原地转发消息 */
+    void signal_recvMessage(const QMQTT::Message& message);
 
 protected:
     /* 接收到消息，子类继承这个解析消息数据 */