|
@@ -113,7 +113,6 @@ class MqttServerDeviceGateway implements DeviceGateway, MonitorSupportDeviceGate
|
|
|
.flatMap(this::handleConnection)
|
|
|
.flatMap(tuple3 -> handleAuthResponse(tuple3.getT1(), tuple3.getT2(), tuple3.getT3()))
|
|
|
.flatMap(tp -> handleAcceptedMqttConnection(tp.getT1(), tp.getT2(), tp.getT3()), Integer.MAX_VALUE)
|
|
|
- .onErrorContinue((err, obj) -> log.error("处理MQTT连接失败", err))
|
|
|
.subscriberContext(ReactiveLogger.start("network", mqttServer.getId()))
|
|
|
.subscribe();
|
|
|
|