From e7dcb6b2875f771eac4daa4655913aa1b48bc60e Mon Sep 17 00:00:00 2001
From: wany <13995595726@qq.com>
Date: Tue, 5 Dec 2023 14:05:06 +0800
Subject: [PATCH] =?UTF-8?q?=E8=A7=A3=E5=86=B3=E7=AA=81=E7=84=B6=E8=8E=B7?=
 =?UTF-8?q?=E5=8F=96=E4=B8=8D=E5=88=B0mqtt=E6=B6=88=E6=81=AF?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/main/java/com/whdc/mqtt/Sub.java | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/src/main/java/com/whdc/mqtt/Sub.java b/src/main/java/com/whdc/mqtt/Sub.java
index 9bca41e..6bc1207 100644
--- a/src/main/java/com/whdc/mqtt/Sub.java
+++ b/src/main/java/com/whdc/mqtt/Sub.java
@@ -41,9 +41,9 @@ public class Sub {
 
             @Override
             public void messageArrived(String topic, MqttMessage mqttMessage) {
-                byte[] payload = mqttMessage.getPayload();
-                String msg = new String(payload);
                 try {
+                    byte[] payload = mqttMessage.getPayload();
+                    String msg = new String(payload);
                     Sub.this.onMessageListener.onMessage(msg);
                 } catch (Throwable e) {
                     e.printStackTrace();