Skip to content

Commit cbe852e

Browse files
committed
refactor: 优化
1 parent a7f5b03 commit cbe852e

1 file changed

Lines changed: 2 additions & 5 deletions

File tree

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

Lines changed: 2 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -28,6 +28,7 @@
2828
import org.jetlinks.core.server.session.PersistentSession;
2929
import org.jetlinks.community.gateway.monitor.DeviceGatewayMonitor;
3030
import org.jetlinks.community.network.mqtt.client.MqttClient;
31+
import org.jetlinks.core.utils.Reactors;
3132
import reactor.core.publisher.Mono;
3233

3334
import java.time.Duration;
@@ -138,11 +139,7 @@ public boolean isAlive() {
138139

139140
@Override
140141
public Mono<Boolean> isAliveAsync() {
141-
return client
142-
.map(client -> {
143-
this.clientTemp = client;
144-
return isAlive();
145-
});
142+
return isAlive() ? Reactors.ALWAYS_TRUE : Reactors.ALWAYS_FALSE;
146143
}
147144

148145
@Override

0 commit comments

Comments
 (0)