From 29cf7e39947e2bf5ccef57542041c65f0083aea5 Mon Sep 17 00:00:00 2001
From: zj <1772600164@qq.com>
Date: Wed, 16 Apr 2025 18:33:38 +0800
Subject: [PATCH] ๆ”ฏไป˜้€š้“

---
 src/main/java/com/nq/ws/WebSocketClientBeanConfig.java |   52 ++++++++++++++++++++++++++--------------------------
 1 files changed, 26 insertions(+), 26 deletions(-)

diff --git a/src/main/java/com/nq/ws/WebSocketClientBeanConfig.java b/src/main/java/com/nq/ws/WebSocketClientBeanConfig.java
index 3b8a3a0..6c310e3 100644
--- a/src/main/java/com/nq/ws/WebSocketClientBeanConfig.java
+++ b/src/main/java/com/nq/ws/WebSocketClientBeanConfig.java
@@ -17,32 +17,32 @@
 public class WebSocketClientBeanConfig {
 
 
-    @Bean
-    public Map<String, WebSocketClient> websocketRunClientMap() {
-
-        Map<String, WebSocketClient> retMap = new HashMap<>(2);
-        try {
-            WebsocketRunClient websocketRunClient = new WebsocketRunClient(new URI(PropertiesUtil.getProperty("JS_IN_WS_URL")),EStockType.IN);
-            websocketRunClient.connect();
-            websocketRunClient.setConnectionLostTimeout(0);
-            new Thread(() -> {
-                while (true) {
-                    try {
-                        Thread.sleep(8000);
-                        websocketRunClient.send("heartbeat".getBytes());
-                    } catch (Exception e) {
-                        websocketRunClient.reconnect();
-                        websocketRunClient.setConnectionLostTimeout(0);
-                    }
-                }
-            }).start();
-        } catch (Exception e) {
-        }
-
-
-
-        return retMap;
-    }
+//    @Bean
+//    public Map<String, WebSocketClient> websocketRunClientMap() {
+//
+//        Map<String, WebSocketClient> retMap = new HashMap<>(2);
+//        try {
+//            WebsocketRunClient websocketRunClient = new WebsocketRunClient(new URI(PropertiesUtil.getProperty("JS_IN_WS_URL")),EStockType.IN);
+//            websocketRunClient.connect();
+//            websocketRunClient.setConnectionLostTimeout(0);
+//            new Thread(() -> {
+//                while (true) {
+//                    try {
+//                        Thread.sleep(8000);
+//                        websocketRunClient.send("heartbeat".getBytes());
+//                    } catch (Exception e) {
+//                        websocketRunClient.reconnect();
+//                        websocketRunClient.setConnectionLostTimeout(0);
+//                    }
+//                }
+//            }).start();
+//        } catch (Exception e) {
+//        }
+//
+//
+//
+//        return retMap;
+//    }
 
 
 }

--
Gitblit v1.9.3