| | |
| | | public synchronized void onMessage(Session session, String message){ |
| | | InterfaceParam param = ActionUtil.getGson().fromJson(message, InterfaceParam.class); |
| | | thread = new Thread("Thread_interfaceDevAlarm") { |
| | | @Override |
| | | public void run() { |
| | | while (runFlag && !isInterrupted()) { |
| | | Thread thread = currentThread(); |
| | |
| | | if (session.isOpen()) { |
| | | //推送信息 |
| | | synchronized (session) { |
| | | session.getBasicRemote().sendObject(service.getDevAlarm(param.getDeviceIds())); |
| | | session.getBasicRemote().sendObject(service.getDevAlarm(param.getDeviceIds(), param.getInterfaceNumber())); |
| | | } |
| | | threadFlagMap.put(thread.getId(),false); |
| | | } |