wany
/
ttssk-service
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

解决突然获取不到mqtt消息

master
wany 2023-12-05 14:05:06 +08:00
parent ded28a8bc1
commit e7dcb6b287
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/main/java/com/whdc/mqtt/Sub.java
View File

@ -41,9 +41,9 @@ public class Sub {
@Override @Override
public void messageArrived(String topic, MqttMessage mqttMessage) { public void messageArrived(String topic, MqttMessage mqttMessage) {
byte[] payload = mqttMessage.getPayload();
String msg = new String(payload);
try { try {
byte[] payload = mqttMessage.getPayload();
String msg = new String(payload);
Sub.this.onMessageListener.onMessage(msg); Sub.this.onMessageListener.onMessage(msg);
} catch (Throwable e) { } catch (Throwable e) {
e.printStackTrace(); e.printStackTrace();