| | |
|---|
| | | } catch (Exception e) { |
|---|
| | | } |
|---|
| | | |
|---|
| | | // try { |
|---|
| | | // USWebsocketRunClient usWebsocketRunClient = new USWebsocketRunClient(new URI(PropertiesUtil.getProperty("US_WS_URL")),EStockType.US); |
|---|
| | | // 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(); |
|---|
| | | // } catch (Exception e) { |
|---|
| | | // } |
|---|
| | | |
|---|
| | | |
|---|
| | | return retMap; |
|---|
| | | } |
|---|
| | | |
|---|
| | | |
|---|
| | | |
|---|
| | | } |
|---|
