This is an automated email from the ASF dual-hosted git repository.
crazyhzm pushed a commit to branch 3.0
in repository https://gitbox.apache.org/repos/asf/dubbo.git
The following commit(s) were added to refs/heads/3.0 by this push:
new bc8cb85 set super class of AvailableCluster to AbstractCluster (#9351)
bc8cb85 is described below
commit bc8cb85fec79d10f03825d12c65a85f656a46f65
Author: 王贺涛 <[email protected]>
AuthorDate: Sun Dec 5 21:46:16 2021 +0800
set super class of AvailableCluster to AbstractCluster (#9351)
* set super class of AvailableCluster to AbstractCluster
* delete useless imports
---
.../org/apache/dubbo/rpc/cluster/support/AvailableCluster.java | 8 +++-----
1 file changed, 3 insertions(+), 5 deletions(-)
diff --git
a/dubbo-cluster/src/main/java/org/apache/dubbo/rpc/cluster/support/AvailableCluster.java
b/dubbo-cluster/src/main/java/org/apache/dubbo/rpc/cluster/support/AvailableCluster.java
index d6c0163..d84258f 100644
---
a/dubbo-cluster/src/main/java/org/apache/dubbo/rpc/cluster/support/AvailableCluster.java
+++
b/dubbo-cluster/src/main/java/org/apache/dubbo/rpc/cluster/support/AvailableCluster.java
@@ -16,22 +16,20 @@
*/
package org.apache.dubbo.rpc.cluster.support;
-import org.apache.dubbo.rpc.Invoker;
import org.apache.dubbo.rpc.RpcException;
-import org.apache.dubbo.rpc.cluster.Cluster;
import org.apache.dubbo.rpc.cluster.Directory;
+import org.apache.dubbo.rpc.cluster.support.wrapper.AbstractCluster;
/**
* AvailableCluster
*
*/
-public class AvailableCluster implements Cluster {
+public class AvailableCluster extends AbstractCluster {
public static final String NAME = "available";
@Override
- public <T> Invoker<T> join(Directory<T> directory, boolean
buildFilterChain) throws RpcException {
+ public <T> AbstractClusterInvoker<T> doJoin(Directory<T> directory) throws
RpcException {
return new AvailableClusterInvoker<>(directory);
}
-
}