suguo
/
jetlinks-community
mirror of https://gitee.com/jetlinks/jetlinks-community.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

refactor: 优化

This commit is contained in:
zhouhao 2025-09-11 09:43:39 +08:00
parent a7f5b03e6c
commit cbe852e290
1 changed files with 2 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
jetlinks-components/network-component/mqtt-component/src/main/java/org/jetlinks/community/network/mqtt/gateway/device/session/MqttClientSession.java
View File

@ -28,6 +28,7 @@ import org.jetlinks.core.message.codec.Transport;
import org.jetlinks.core.server.session.PersistentSession;
import org.jetlinks.community.gateway.monitor.DeviceGatewayMonitor;
import org.jetlinks.community.network.mqtt.client.MqttClient;
import org.jetlinks.core.utils.Reactors;
import reactor.core.publisher.Mono;
import java.time.Duration;
@ -138,11 +139,7 @@ public class MqttClientSession implements PersistentSession {
@Override
public Mono<Boolean> isAliveAsync() {
return client
.map(client -> {
this.clientTemp = client;
return isAlive();
});
return isAlive() ? Reactors.ALWAYS_TRUE : Reactors.ALWAYS_FALSE;
}
@Override