From 9718d2aa5f2bbd3435723cb1bd938b5c8e36bf63 Mon Sep 17 00:00:00 2001 From: zhou-hao Date: Thu, 10 Dec 2020 17:55:48 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8Dtcp=E5=8F=AF=E8=83=BD?= =?UTF-8?q?=E6=97=A0=E6=B3=95=E8=8E=B7=E5=8F=96=E5=88=B0session=E7=9A=84?= =?UTF-8?q?=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../community/network/tcp/device/TcpServerDeviceGateway.java | 1 + 1 file changed, 1 insertion(+) diff --git a/jetlinks-components/network-component/tcp-component/src/main/java/org/jetlinks/community/network/tcp/device/TcpServerDeviceGateway.java b/jetlinks-components/network-component/tcp-component/src/main/java/org/jetlinks/community/network/tcp/device/TcpServerDeviceGateway.java index d1a13f7f..82587c1c 100644 --- a/jetlinks-components/network-component/tcp-component/src/main/java/org/jetlinks/community/network/tcp/device/TcpServerDeviceGateway.java +++ b/jetlinks-components/network-component/tcp-component/src/main/java/org/jetlinks/community/network/tcp/device/TcpServerDeviceGateway.java @@ -186,6 +186,7 @@ class TcpServerDeviceGateway implements DeviceGateway, MonitorSupportDeviceGatew .andThen(session -> { TcpDeviceSession deviceSession = session.unwrap(TcpDeviceSession.class); deviceSession.setClient(client); + sessionRef.set(deviceSession); }), () -> log.warn("无法从tcp[{}]消息中获取设备信息:{}", address, message) )