From bec8be9f4ac68b5642f931c863fe61a6a00f0e47 Mon Sep 17 00:00:00 2001 From: hengboy Date: Tue, 25 Aug 2020 17:23:29 +0800 Subject: [PATCH] =?UTF-8?q?:bug:=20=E4=BF=AE=E5=A4=8DClient=E5=90=AF?= =?UTF-8?q?=E5=8A=A8=E6=97=B6=E4=B8=80=E7=9B=B4=E9=87=8D=E8=AF=95=E6=B3=A8?= =?UTF-8?q?=E5=86=8C=E5=88=B0Server=EF=BC=8C=E5=AF=BC=E8=87=B4=E9=98=BB?= =?UTF-8?q?=E5=A1=9E=E4=B8=BB=E7=BA=BF=E7=A8=8B?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../message/pipe/client/connect/ConnectServerExecutor.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/message-pipe-client/src/main/java/org/minbox/framework/message/pipe/client/connect/ConnectServerExecutor.java b/message-pipe-client/src/main/java/org/minbox/framework/message/pipe/client/connect/ConnectServerExecutor.java index 2e0947b..f9dd218 100644 --- a/message-pipe-client/src/main/java/org/minbox/framework/message/pipe/client/connect/ConnectServerExecutor.java +++ b/message-pipe-client/src/main/java/org/minbox/framework/message/pipe/client/connect/ConnectServerExecutor.java @@ -148,7 +148,8 @@ private void heartBeat() { */ @Override public void afterPropertiesSet() throws Exception { - this.register(); + Thread registerThread = new Thread(() -> this.register()); + registerThread.start(); this.heartBeat(); } }