From d2b21bc8fd32da4ac29518a0c07f95c140f287b3 Mon Sep 17 00:00:00 2001 From: jinpengyong <jpy123456> Date: Thu, 15 Oct 2020 14:47:07 +0800 Subject: [PATCH] update --- src/main/java/com/moral/webSocketServer/WebSocketServerNew.java | 3 ++- 1 files changed, 2 insertions(+), 1 deletions(-) diff --git a/src/main/java/com/moral/webSocketServer/WebSocketServerNew.java b/src/main/java/com/moral/webSocketServer/WebSocketServerNew.java index deac7a4..1b6f298 100644 --- a/src/main/java/com/moral/webSocketServer/WebSocketServerNew.java +++ b/src/main/java/com/moral/webSocketServer/WebSocketServerNew.java @@ -52,12 +52,13 @@ this.session = session; //������������������������������������������������ webSocketSet.add(this); + //������ String[] flag=param.split("&"); - String orgId = flag[0]; String accountId = flag[1]; String monitPointId = flag[2]; String p=flag[3]; + String QUEUE_NAME = "deviceData_" + accountId; Map<String, Object> paramMap = new HashMap<String, Object>(); List<Device> deviceList = deviceService.getDeviceById2(Integer.parseInt(monitPointId)); -- Gitblit v1.8.0