You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@dubbo.apache.org by li...@apache.org on 2021/03/04 08:06:41 UTC
[dubbo] branch patch-2-reconnect created (now b5b96f9)
This is an automated email from the ASF dual-hosted git repository.
liujun pushed a change to branch patch-2-reconnect
in repository https://gitbox.apache.org/repos/asf/dubbo.git.
at b5b96f9 Fix client connection cannot reconnect when channel down.
This branch includes the following new commits:
new b5b96f9 Fix client connection cannot reconnect when channel down.
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
[dubbo] 01/01: Fix client connection cannot reconnect when channel
down.
Posted by li...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
liujun pushed a commit to branch patch-2-reconnect
in repository https://gitbox.apache.org/repos/asf/dubbo.git
commit b5b96f9e7412d7a8434e331fb0d5831a22441aa6
Author: ken.lj <ke...@gmail.com>
AuthorDate: Thu Mar 4 16:05:54 2021 +0800
Fix client connection cannot reconnect when channel down.
---
.../apache/dubbo/rpc/protocol/dubbo/ReferenceCountExchangeClient.java | 3 +--
1 file changed, 1 insertion(+), 2 deletions(-)
diff --git a/dubbo-rpc/dubbo-rpc-dubbo/src/main/java/org/apache/dubbo/rpc/protocol/dubbo/ReferenceCountExchangeClient.java b/dubbo-rpc/dubbo-rpc-dubbo/src/main/java/org/apache/dubbo/rpc/protocol/dubbo/ReferenceCountExchangeClient.java
index 8c4d07b..1739600 100644
--- a/dubbo-rpc/dubbo-rpc-dubbo/src/main/java/org/apache/dubbo/rpc/protocol/dubbo/ReferenceCountExchangeClient.java
+++ b/dubbo-rpc/dubbo-rpc-dubbo/src/main/java/org/apache/dubbo/rpc/protocol/dubbo/ReferenceCountExchangeClient.java
@@ -29,7 +29,6 @@ import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.atomic.AtomicInteger;
-import static org.apache.dubbo.remoting.Constants.RECONNECT_KEY;
import static org.apache.dubbo.remoting.Constants.SEND_RECONNECT_KEY;
import static org.apache.dubbo.rpc.protocol.dubbo.Constants.LAZY_CONNECT_INITIAL_STATE_KEY;
@@ -181,7 +180,7 @@ final class ReferenceCountExchangeClient implements ExchangeClient {
private void replaceWithLazyClient() {
// this is a defensive operation to avoid client is closed by accident, the initial state of the client is false
URL lazyUrl = url.addParameter(LAZY_CONNECT_INITIAL_STATE_KEY, Boolean.TRUE)
- .addParameter(RECONNECT_KEY, Boolean.FALSE)
+ //.addParameter(RECONNECT_KEY, Boolean.FALSE)
.addParameter(SEND_RECONNECT_KEY, Boolean.TRUE.toString())
.addParameter(LazyConnectExchangeClient.REQUEST_WITH_WARNING_KEY, true);