Skip to content

Commit d269b23

Browse files
committed
deal server failed, but client connect status not update
1 parent 2c06f2f commit d269b23

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

toolkit-mqtt/src/main/java/iot/technology/client/toolkit/mqtt/command/sub/MqttShellCommand.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,6 @@
1616
package iot.technology.client.toolkit.mqtt.command.sub;
1717

1818
import iot.technology.client.toolkit.common.constants.ExitCodeEnum;
19-
import iot.technology.client.toolkit.common.constants.MqttBizEnum;
2019
import iot.technology.client.toolkit.common.rule.NodeContext;
2120
import iot.technology.client.toolkit.common.rule.TkNode;
2221
import iot.technology.client.toolkit.common.utils.ObjectUtils;

toolkit-mqtt/src/main/java/iot/technology/client/toolkit/mqtt/service/MqttShellModeService.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -92,10 +92,11 @@ public boolean call(MqttShellModeDomain domain, Terminal terminal) {
9292
MqttClientCallback clientCallback = new MqttClientCallback() {
9393
@Override
9494
public void connectionLost(DisReason reason) {
95+
mqttSettingService.updateAllMqttConfigsByUsage(domain.getSettings(), 0);
9596
if (reason.getActionType().equals(0)) {
9697
StringBuilder sb = new StringBuilder();
9798
sb.append(StringUtils.lineSeparator);
98-
sb.append("Server Unavailable" + String.format(EmojiEnum.disconnectEmoji) + " channel is close!");
99+
sb.append("Server Unavailable" + String.format(EmojiEnum.disconnectEmoji));
99100
System.out.print(sb);
100101
System.exit(0);
101102
}

0 commit comments

Comments
 (0)