1

zyy

2 days ago 01b3fecb2d1b03861a72d53a7afea6ca557a209c

 src/main/java/com/nq/ws/WebSocketClientBeanConfig.java

@@ -21,22 +21,22 @@

        Map<String, WebSocketClient> retMap = new HashMap<>(2);
        try {
            WebsocketRunClient usWebsocketRunClient = new WebsocketRunClient(new URI(PropertiesUtil.getProperty("US_WS_URL")),EStockType.US);
            JPWebsocketRunClient jpWebsocketRunClient = new JPWebsocketRunClient(new URI(PropertiesUtil.getProperty("JP_WS_URL")), EStockType.JP);
            jpWebsocketRunClient.connect();
            jpWebsocketRunClient.setConnectionLostTimeout(0);
            startHeartbeatThread(jpWebsocketRunClient);
            retMap.put(EStockType.JP.getStockKey(), jpWebsocketRunClient);
        } catch (Exception e) {
            log.error("jpWebsocketRunClient 异常: {}", e.getMessage());
        }
        try {
            USWebsocketRunClient usWebsocketRunClient = new USWebsocketRunClient(new URI(PropertiesUtil.getProperty("US_WS_URL")), EStockType.US);
            usWebsocketRunClient.connect();
            usWebsocketRunClient.setConnectionLostTimeout(0);
            startHeartbeatThread(usWebsocketRunClient);
            retMap.put(EStockType.US.getStockKey(), usWebsocketRunClient);
        } catch (Exception e) {
            log.error("usWebsocketRunClient 异常: {}", e.getMessage());
        }
        try {
            MXWebsocketRunClient mxWebsocketRunClient = new MXWebsocketRunClient(new URI(PropertiesUtil.getProperty("MX_WS_URL")),EStockType.MX);
            mxWebsocketRunClient.connect();
            mxWebsocketRunClient.setConnectionLostTimeout(0);
            startHeartbeatThread(mxWebsocketRunClient);
            retMap.put(EStockType.MX.getStockKey(), mxWebsocketRunClient);
        } catch (Exception e) {
            log.error("mxWebsocketRunClient 异常: {}", e.getMessage());
        }
        return retMap;
    }
@@ -66,4 +66,5 @@
    }


}
}