|
@@ -158,10 +158,12 @@ class TcpServerDeviceGateway implements DeviceGateway, MonitorSupportDeviceGatew
|
|
|
}
|
|
|
|
|
|
Mono<Void> handleTcpMessage(TcpMessage message) {
|
|
|
+
|
|
|
return getProtocol()
|
|
|
.flatMap(pt -> pt.getMessageCodec(getTransport()))
|
|
|
.flatMapMany(codec -> codec.decode(FromDeviceMessageContext.of(sessionRef.get(), message)))
|
|
|
.cast(DeviceMessage.class)
|
|
|
+ .doOnNext(msg-> gatewayMonitor.receivedMessage())
|
|
|
.flatMap(this::handleDeviceMessage)
|
|
|
.doOnEach(ReactiveLogger.onError(err ->
|
|
|
log.error("处理TCP[{}]消息失败:\n{}",
|