| | |
| | | public void onOpen(@PathParam(value = "type") String type, |
| | | @PathParam(value = "param") String param, Session session) { |
| | | //停牌断开连接 |
| | | if (WebSocketEnum.SOCKET_ENUM_DEPTH.getCode().equals(type)) { |
| | | /*if (WebSocketEnum.SOCKET_ENUM_DEPTH.getCode().equals(type)) { |
| | | List<Item> items = ApplicationContextUtils.getApplicationContext().getBean(ItemService.class).list(); |
| | | if (CollectionUtil.isNotEmpty(items)) { |
| | | Item item = items.stream().filter(i -> param.equalsIgnoreCase(i.getSymbol())).findFirst().orElse(null); |
| | |
| | | } |
| | | } |
| | | |
| | | } |
| | | }*/ |
| | | |
| | | WebSocketSession webSocketSession = new WebSocketSession(session, getTimeInMillis(), type, param); |
| | | // 加入set中 |