From 69025ab3af5c0eb9bda7f2fe67e60a1314e8b211 Mon Sep 17 00:00:00 2001 From: YevhenBondarenko Date: Fri, 5 Mar 2021 18:17:35 +0200 Subject: [PATCH] TbWebSocketHandler refactoring --- .../server/controller/plugin/TbWebSocketHandler.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/application/src/main/java/org/thingsboard/server/controller/plugin/TbWebSocketHandler.java b/application/src/main/java/org/thingsboard/server/controller/plugin/TbWebSocketHandler.java index 166403f417..0e59030fe2 100644 --- a/application/src/main/java/org/thingsboard/server/controller/plugin/TbWebSocketHandler.java +++ b/application/src/main/java/org/thingsboard/server/controller/plugin/TbWebSocketHandler.java @@ -63,6 +63,7 @@ public class TbWebSocketHandler extends TextWebSocketHandler implements Telemetr private static final ConcurrentMap internalSessionMap = new ConcurrentHashMap<>(); private static final ConcurrentMap externalSessionMap = new ConcurrentHashMap<>(); + private static final ByteBuffer PING_MSG = ByteBuffer.wrap(new byte[]{}); @Autowired private TelemetryWebSocketService webSocketService; @@ -212,7 +213,7 @@ public class TbWebSocketHandler extends TextWebSocketHandler implements Telemetr synchronized void sendPing(long currentTime) { try { if (currentTime - lastActivityTime >= pingTimeout) { - this.asyncRemote.sendPing(ByteBuffer.wrap(new byte[]{})); + this.asyncRemote.sendPing(PING_MSG); lastActivityTime = currentTime; } } catch (Exception e) {