|
@@ -36,7 +36,7 @@ public class PublishCallback implements MqttCallback {
|
|
|
logger.error("连接断开,原因:" + cause);
|
|
|
try {
|
|
|
logger.error("------connectionLost-------");
|
|
|
- publishClient.reconnect();
|
|
|
+ PublishClient.reconnect();
|
|
|
} catch (Exception e) {
|
|
|
logger.error("重连失败:" + e);
|
|
|
}
|