parent
60e6720511
commit
ed156a00f9
|
@ -215,6 +215,9 @@ public class MqttVerticle extends AbstractVerticle implements Handler<MqttEndpoi
|
|||
endpointMap.remove(deviceName);
|
||||
MQTT_CONNECT_POOL.put(clientId, false);
|
||||
DEVICE_ONLINE.clear();
|
||||
}).pingHandler(msg->{
|
||||
// 心跳 ping
|
||||
ping(productKey,deviceName);
|
||||
}).subscribeHandler(subscribe -> {
|
||||
List<MqttSubAckReasonCode> reasonCodes = new ArrayList<>();
|
||||
for (MqttTopicSubscription s : subscribe.topicSubscriptions()) {
|
||||
|
@ -418,6 +421,18 @@ public class MqttVerticle extends AbstractVerticle implements Handler<MqttEndpoi
|
|||
}
|
||||
}
|
||||
|
||||
private void ping(String productKey, String deviceName) {
|
||||
thingService.post(
|
||||
pluginInfo.getPluginId(),
|
||||
fillAction(
|
||||
DevicePing.builder()
|
||||
.productKey(productKey)
|
||||
.deviceName(deviceName)
|
||||
.build()
|
||||
)
|
||||
);
|
||||
}
|
||||
|
||||
private void offline(String productKey, String deviceName) {
|
||||
thingService.post(
|
||||
pluginInfo.getPluginId(),
|
||||
|
|
Loading…
Reference in New Issue