From 79402950be7015226b7120526ec3525ea3a762ea Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E7=BB=9D=E5=B0=98?= <237809796@qq.com>
Date: Thu, 9 May 2024 22:55:55 +0800
Subject: [PATCH] .

---
 src/main/java/net/tccn/zhub/ZHubClient.java | 7 +++----
 1 file changed, 3 insertions(+), 4 deletions(-)

diff --git a/src/main/java/net/tccn/zhub/ZHubClient.java b/src/main/java/net/tccn/zhub/ZHubClient.java
index fea63eb..b9490a4 100644
--- a/src/main/java/net/tccn/zhub/ZHubClient.java
+++ b/src/main/java/net/tccn/zhub/ZHubClient.java
@@ -75,12 +75,11 @@ public class ZHubClient extends AbstractConsumer implements IConsumer, IProducer
         }
 
         CompletableFuture.runAsync(() -> {
+            if (!initSocket(0)) {
+                return;
+            }
             // 消息 事件接收
             new Thread(() -> {
-                if (!initSocket(0)) {
-                    return;
-                }
-
                 while (true) {
                     try {
                         String readLine = reader.readLine();