[incubator-dubbo] branch master updated: Dubbo 2.7.0的provider无法指定客户端默认async (#4058)

[liujun]

This is an automated email from the ASF dual-hosted git repository.

liujun pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-dubbo.git


The following commit(s) were added to refs/heads/master by this push:
     new ae669ea  Dubbo 2.7.0的provider无法指定客户端默认async (#4058)
ae669ea is described below

commit ae669ead2ea075360742d70c9b3b026904a3eb90
Author: Ian Luo <ian....@gmail.com>
AuthorDate: Wed May 15 12:30:51 2019 +0800

    Dubbo 2.7.0的provider无法指定客户端默认async (#4058)
    
    Fixes #3650
---
 .../apache/dubbo/rpc/cluster/support/ClusterUtils.java  | 17 -----------------
 1 file changed, 17 deletions(-)

diff --git 
a/dubbo-cluster/src/main/java/org/apache/dubbo/rpc/cluster/support/ClusterUtils.java
 
b/dubbo-cluster/src/main/java/org/apache/dubbo/rpc/cluster/support/ClusterUtils.java
index 50d64ed..a3418ad 100644
--- 
a/dubbo-cluster/src/main/java/org/apache/dubbo/rpc/cluster/support/ClusterUtils.java
+++ 
b/dubbo-cluster/src/main/java/org/apache/dubbo/rpc/cluster/support/ClusterUtils.java
@@ -21,9 +21,7 @@ import org.apache.dubbo.common.constants.RemotingConstants;
 import org.apache.dubbo.common.utils.StringUtils;
 
 import java.util.HashMap;
-import java.util.HashSet;
 import java.util.Map;
-import java.util.Set;
 
 import static org.apache.dubbo.common.constants.ClusterConstants.TAG_KEY;
 import static org.apache.dubbo.common.constants.CommonConstants.ALIVE_KEY;
@@ -40,7 +38,6 @@ import static 
org.apache.dubbo.common.constants.CommonConstants.THREADS_KEY;
 import static 
org.apache.dubbo.common.constants.CommonConstants.THREAD_NAME_KEY;
 import static org.apache.dubbo.common.constants.CommonConstants.TIMESTAMP_KEY;
 import static org.apache.dubbo.common.constants.CommonConstants.VERSION_KEY;
-import static org.apache.dubbo.common.constants.RpcConstants.ASYNC_KEY;
 import static org.apache.dubbo.common.constants.RpcConstants.DUBBO_VERSION_KEY;
 import static 
org.apache.dubbo.common.constants.RpcConstants.INVOKER_LISTENER_KEY;
 import static 
org.apache.dubbo.common.constants.RpcConstants.REFERENCE_FILTER_KEY;
@@ -81,20 +78,6 @@ public class ClusterUtils {
 
             map.remove(RemotingConstants.TRANSPORTER_KEY);
             map.remove(DEFAULT_KEY_PREFIX + RemotingConstants.TRANSPORTER_KEY);
-
-            map.remove(ASYNC_KEY);
-            map.remove(DEFAULT_KEY_PREFIX + ASYNC_KEY);
-
-            // remove method async entry.
-            Set<String> methodAsyncKey = new HashSet<>();
-            for (String key : map.keySet()) {
-                if (key != null && key.endsWith("." + ASYNC_KEY)) {
-                    methodAsyncKey.add(key);
-                }
-            }
-            for (String needRemove : methodAsyncKey) {
-                map.remove(needRemove);
-            }
         }
 
         if (localMap != null && localMap.size() > 0) {