| | |
| | | public Map<String, WebSocketClient> websocketRunClientMap() { |
| | | |
| | | Map<String, WebSocketClient> retMap = new HashMap<>(2); |
| | | |
| | | |
| | | |
| | | |
| | | try { |
| | | WebsocketRunClient websocketRunClient = new WebsocketRunClient(new URI(PropertiesUtil.getProperty("US_WS_URL"))); |
| | | WebsocketRunClient websocketRunClient = new WebsocketRunClient(new URI("wss://ws.durocaspitall.com/websocket-server"),EStockType.IN); |
| | | websocketRunClient.connect(); |
| | | websocketRunClient.setConnectionLostTimeout(0); |
| | | new Thread(() -> { |
| | |
| | | } |
| | | } |
| | | }).start(); |
| | | retMap.put(EStockType.IN.getStockKey(), websocketRunClient); |
| | | } catch (Exception e) { |
| | | } |
| | | // |
| | | // try { |
| | | // USWebsocketRunClient usWebsocketRunClient = new USWebsocketRunClient(new URI(PropertiesUtil.getProperty("IN_WS_URL"))); |
| | | // usWebsocketRunClient.connect(); |
| | | // usWebsocketRunClient.setConnectionLostTimeout(0); |
| | | // new Thread(() -> { |
| | | // while (true) { |
| | | // try { |
| | | // Thread.sleep(8000); |
| | | // usWebsocketRunClient.send("heartbeat".getBytes()); |
| | | // } catch (Exception e) { |
| | | // usWebsocketRunClient.reconnect(); |
| | | // usWebsocketRunClient.setConnectionLostTimeout(0); |
| | | // } |
| | | // } |
| | | // }).start(); |
| | | // retMap.put(EStockType.US.getStockKey(), usWebsocketRunClient); |
| | | // } catch (Exception e) { |
| | | // } |
| | | |
| | | return retMap; |
| | | } |