From 489f729b5e15fc62ac5fef540a9b5f1995f0bce7 Mon Sep 17 00:00:00 2001 From: "ken.lj" Date: Fri, 23 Jul 2021 10:24:44 +0800 Subject: [PATCH] fix log does not match --- .../dubbo/rpc/protocol/dubbo/LazyConnectExchangeClient.java | 2 +- .../rpc/protocol/dubbo/ReferenceCountExchangeClientTest.java | 3 +-- 2 files changed, 2 insertions(+), 3 deletions(-) diff --git a/dubbo-rpc/dubbo-rpc-dubbo/src/main/java/com/alibaba/dubbo/rpc/protocol/dubbo/LazyConnectExchangeClient.java b/dubbo-rpc/dubbo-rpc-dubbo/src/main/java/com/alibaba/dubbo/rpc/protocol/dubbo/LazyConnectExchangeClient.java index c5a1307e360..bc230a26dbf 100644 --- a/dubbo-rpc/dubbo-rpc-dubbo/src/main/java/com/alibaba/dubbo/rpc/protocol/dubbo/LazyConnectExchangeClient.java +++ b/dubbo-rpc/dubbo-rpc-dubbo/src/main/java/com/alibaba/dubbo/rpc/protocol/dubbo/LazyConnectExchangeClient.java @@ -115,7 +115,7 @@ public ResponseFuture request(Object request, int timeout) throws RemotingExcept private void warning(Object request) { if (requestWithWarning) { if (warningcount.get() % 5000 == 0) { - logger.warn(url.getAddress() + " " + url.getServiceKey() + " safeguard client get called after real client closed, recreating connection..."); + logger.warn(url.getAddress() + " " + url.getServiceKey() + " safe guard client get called after real client closed, recreating connection..."); } warningcount.incrementAndGet(); } diff --git a/dubbo-rpc/dubbo-rpc-dubbo/src/test/java/com/alibaba/dubbo/rpc/protocol/dubbo/ReferenceCountExchangeClientTest.java b/dubbo-rpc/dubbo-rpc-dubbo/src/test/java/com/alibaba/dubbo/rpc/protocol/dubbo/ReferenceCountExchangeClientTest.java index d9b64c2fa3b..452e6a919e1 100644 --- a/dubbo-rpc/dubbo-rpc-dubbo/src/test/java/com/alibaba/dubbo/rpc/protocol/dubbo/ReferenceCountExchangeClientTest.java +++ b/dubbo-rpc/dubbo-rpc-dubbo/src/test/java/com/alibaba/dubbo/rpc/protocol/dubbo/ReferenceCountExchangeClientTest.java @@ -26,7 +26,6 @@ import com.alibaba.dubbo.rpc.Exporter; import com.alibaba.dubbo.rpc.Invoker; import com.alibaba.dubbo.rpc.ProxyFactory; - import org.junit.Assert; import org.junit.Before; import org.junit.BeforeClass; @@ -46,7 +45,7 @@ public class ReferenceCountExchangeClientTest { IHelloService helloService; ExchangeClient demoClient; ExchangeClient helloClient; - String errorMsg = "safe guard client , should not be called ,must have a bug"; + String errorMsg = "safe guard client"; @BeforeClass public static void setUpBeforeClass() throws Exception {