From 81e871cca925c0ccf46486aa38b330d7da509e34 Mon Sep 17 00:00:00 2001
From: redkale <redkale@qq.com>
Date: Mon, 3 Jul 2023 16:03:06 +0800
Subject: [PATCH] =?UTF-8?q?ClientConnection=E4=BC=98=E5=8C=96?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/test/java/org/redkale/test/sncp/SncpSleepService.java | 3 +++
 src/test/java/org/redkale/test/sncp/SncpSleepTest.java    | 2 +-
 2 files changed, 4 insertions(+), 1 deletion(-)

diff --git a/src/test/java/org/redkale/test/sncp/SncpSleepService.java b/src/test/java/org/redkale/test/sncp/SncpSleepService.java
index a056a5e10..c618ed6e2 100644
--- a/src/test/java/org/redkale/test/sncp/SncpSleepService.java
+++ b/src/test/java/org/redkale/test/sncp/SncpSleepService.java
@@ -16,6 +16,7 @@ public class SncpSleepService extends AbstractService {
     public CompletableFuture<String> sleep200() {
         return (CompletableFuture) CompletableFuture.supplyAsync(() -> {
             Utility.sleep(200);
+            System.out.println("执行完sleep200");
             return "ok200";
         });
     }
@@ -23,6 +24,7 @@ public class SncpSleepService extends AbstractService {
     public CompletableFuture<String> sleep300() {
         return (CompletableFuture) CompletableFuture.supplyAsync(() -> {
             Utility.sleep(300);
+            System.out.println("执行完sleep300");
             return "ok300";
         });
     }
@@ -30,6 +32,7 @@ public class SncpSleepService extends AbstractService {
     public CompletableFuture<String> sleep500() {
         return (CompletableFuture) CompletableFuture.supplyAsync(() -> {
             Utility.sleep(500);
+            System.out.println("执行完sleep500");
             return "ok500";
         });
     }
diff --git a/src/test/java/org/redkale/test/sncp/SncpSleepTest.java b/src/test/java/org/redkale/test/sncp/SncpSleepTest.java
index 79e75b887..c340a49dc 100644
--- a/src/test/java/org/redkale/test/sncp/SncpSleepTest.java
+++ b/src/test/java/org/redkale/test/sncp/SncpSleepTest.java
@@ -44,7 +44,7 @@ public class SncpSleepTest {
         server.start();
 
         int port = server.getSocketAddress().getPort();
-        System.out.println("服务器启动端口: " + port);
+        System.out.println("SNCP服务器启动端口: " + port);
         InetSocketAddress sncpAddress = new InetSocketAddress("127.0.0.1", port);
         final SncpClient client = new SncpClient("", asyncGroup, sncpAddress, new ClientAddress(sncpAddress), "TCP", 16, 100);
         final SncpRpcGroups rpcGroups = application.getSncpRpcGroups();