From bb272e1e2c0d4637d6d9ebfefb635662b804b459 Mon Sep 17 00:00:00 2001
From: Administrator <15274802129@163.com>
Date: Wed, 13 May 2026 17:52:48 +0800
Subject: [PATCH] refactor(okxNewPrice): 账户配置
---
src/main/java/com/xcong/excoin/modules/okxApi/OkxKlineWebSocketClient.java | 9 +++++++++
1 files changed, 9 insertions(+), 0 deletions(-)
diff --git a/src/main/java/com/xcong/excoin/modules/okxApi/OkxKlineWebSocketClient.java b/src/main/java/com/xcong/excoin/modules/okxApi/OkxKlineWebSocketClient.java
index 014d2f5..b043658 100644
--- a/src/main/java/com/xcong/excoin/modules/okxApi/OkxKlineWebSocketClient.java
+++ b/src/main/java/com/xcong/excoin/modules/okxApi/OkxKlineWebSocketClient.java
@@ -66,8 +66,14 @@
private final List<OkxChannelHandler> channelHandlers = new ArrayList<>();
+ private volatile Runnable onLoginSuccess;
+
public WebSocketClient getWebSocketClient() {
return webSocketClient;
+ }
+
+ public void setOnLoginSuccess(Runnable onLoginSuccess) {
+ this.onLoginSuccess = onLoginSuccess;
}
private final ExecutorService sharedExecutor = Executors.newCachedThreadPool(r -> {
@@ -249,6 +255,9 @@
handler.subscribe(webSocketClient);
}
sendPing();
+ if (onLoginSuccess != null) {
+ onLoginSuccess.run();
+ }
} else {
log.error("[WS] WebSocket登录失败, code:{}, msg:{}", code, response.getString("msg"));
}
--
Gitblit v1.9.1