From a818be0a541ea27e827c5b2abe956056dd66d637 Mon Sep 17 00:00:00 2001
From: Administrator <15274802129@163.com>
Date: Thu, 11 Dec 2025 16:38:00 +0800
Subject: [PATCH] fix(okxNewPrice): 更新订单状态值并修正日志记录
---
src/main/java/com/xcong/excoin/modules/okxNewPrice/OkxQuantWebSocketClient.java | 32 ++++++++++++++++----------------
1 files changed, 16 insertions(+), 16 deletions(-)
diff --git a/src/main/java/com/xcong/excoin/modules/okxNewPrice/OkxQuantWebSocketClient.java b/src/main/java/com/xcong/excoin/modules/okxNewPrice/OkxQuantWebSocketClient.java
index 712e1a0..4b5ebdf 100644
--- a/src/main/java/com/xcong/excoin/modules/okxNewPrice/OkxQuantWebSocketClient.java
+++ b/src/main/java/com/xcong/excoin/modules/okxNewPrice/OkxQuantWebSocketClient.java
@@ -100,9 +100,9 @@
}
shutdownExecutorGracefully(sharedExecutor);
- if (reconnectScheduler != null) {
- reconnectScheduler.shutdownNow();
- }
+// if (reconnectScheduler != null) {
+// reconnectScheduler.shutdownNow();
+// }
}
private void shutdownExecutorGracefully(ExecutorService executor) {
@@ -299,19 +299,19 @@
});
heartbeatExecutor.scheduleWithFixedDelay(this::checkHeartbeatTimeout, 25, 25, TimeUnit.SECONDS);
- // 添加每小时重连的定时任务
- if (reconnectScheduler != null && !reconnectScheduler.isTerminated()) {
- reconnectScheduler.shutdownNow();
- }
-
- reconnectScheduler = Executors.newSingleThreadScheduledExecutor(r -> {
- Thread t = new Thread(r, "okx-scheduled-reconnect");
- t.setDaemon(true);
- return t;
- });
-
- // 每小时执行一次重连
- reconnectScheduler.scheduleWithFixedDelay(this::performScheduledReconnect, 60, 60, TimeUnit.MINUTES);
+// // 添加每小时重连的定时任务
+// if (reconnectScheduler != null && !reconnectScheduler.isTerminated()) {
+// reconnectScheduler.shutdownNow();
+// }
+//
+// reconnectScheduler = Executors.newSingleThreadScheduledExecutor(r -> {
+// Thread t = new Thread(r, "okx-scheduled-reconnect");
+// t.setDaemon(true);
+// return t;
+// });
+//
+// // 每小时执行一次重连
+// reconnectScheduler.scheduleWithFixedDelay(this::performScheduledReconnect, 60, 60, TimeUnit.MINUTES);
}
/**
--
Gitblit v1.9.1