|
21 | 21 | import org.apache.dubbo.common.utils.StringUtils; |
22 | 22 |
|
23 | 23 | import java.util.HashMap; |
24 | | -import java.util.HashSet; |
25 | 24 | import java.util.Map; |
26 | | -import java.util.Set; |
27 | 25 |
|
28 | 26 | import static org.apache.dubbo.common.constants.ClusterConstants.TAG_KEY; |
29 | 27 | import static org.apache.dubbo.common.constants.CommonConstants.ALIVE_KEY; |
|
40 | 38 | import static org.apache.dubbo.common.constants.CommonConstants.THREAD_NAME_KEY; |
41 | 39 | import static org.apache.dubbo.common.constants.CommonConstants.TIMESTAMP_KEY; |
42 | 40 | import static org.apache.dubbo.common.constants.CommonConstants.VERSION_KEY; |
43 | | -import static org.apache.dubbo.common.constants.RpcConstants.ASYNC_KEY; |
44 | 41 | import static org.apache.dubbo.common.constants.RpcConstants.DUBBO_VERSION_KEY; |
45 | 42 | import static org.apache.dubbo.common.constants.RpcConstants.INVOKER_LISTENER_KEY; |
46 | 43 | import static org.apache.dubbo.common.constants.RpcConstants.REFERENCE_FILTER_KEY; |
@@ -81,20 +78,6 @@ public static URL mergeUrl(URL remoteUrl, Map<String, String> localMap) { |
81 | 78 |
|
82 | 79 | map.remove(RemotingConstants.TRANSPORTER_KEY); |
83 | 80 | map.remove(DEFAULT_KEY_PREFIX + RemotingConstants.TRANSPORTER_KEY); |
84 | | - |
85 | | - map.remove(ASYNC_KEY); |
86 | | - map.remove(DEFAULT_KEY_PREFIX + ASYNC_KEY); |
87 | | - |
88 | | - // remove method async entry. |
89 | | - Set<String> methodAsyncKey = new HashSet<>(); |
90 | | - for (String key : map.keySet()) { |
91 | | - if (key != null && key.endsWith("." + ASYNC_KEY)) { |
92 | | - methodAsyncKey.add(key); |
93 | | - } |
94 | | - } |
95 | | - for (String needRemove : methodAsyncKey) { |
96 | | - map.remove(needRemove); |
97 | | - } |
98 | 81 | } |
99 | 82 |
|
100 | 83 | if (localMap != null && localMap.size() > 0) { |
|
0 commit comments