1

zj

2026-01-14 af7f754c7eeb82a7ec7570d1396ff91848d83ca7

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

@@ -29,15 +29,15 @@
//        } 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 {
//            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());
//        }
        return retMap;
    }