blog

cluster$adaptive

public class Cluster$Adaptive { クラスターアダプティブ パブリック...

Apr 7, 2020 · 1 min. read
Share this
public class Cluster$Adaptive implements org.apache.dubbo.rpc.cluster.Cluster {
	public org.apache.dubbo.rpc.Invoker join(org.apache.dubbo.rpc.cluster.Directory arg0) throws org.apache.dubbo.rpc.RpcException {
		if (arg0 == null) 
			throw new IllegalArgumentException("org.apache.dubbo.rpc.cluster.Directory argument == null");
		if (arg0.getUrl() == null) 
			throw new IllegalArgumentException("org.apache.dubbo.rpc.cluster.Directory argument getUrl() == null");
		org.apache.dubbo.common.URL url = arg0.getUrl();
		String extName = url.getParameter("cluster", "failover");
		if(extName == null) 
			throw new IllegalStateException("Failed to get extension (org.apache.dubbo.rpc.cluster.Cluster) name from url (" + url.toString() + ") use keys([cluster])");
		org.apache.dubbo.rpc.cluster.Cluster extension = (org.apache.dubbo.rpc.cluster.Cluster)ExtensionLoader.getExtensionLoader(org.apache.dubbo.rpc.cluster.Cluster.class).getExtension(extName);
		return extension.join(arg0);
	}
}



Read next

遅延タスク - DelayQueue

1. 使い方 2. ソースコードの解析 3. まとめ 1. 使い方 2. ソースコードの解析 ソースコードを通して、add、offer、put、offer という合計 4 つのキューイングメソッドがあることがわかりますが、実はこれらはすべて offer の実装の呼び出しです。 3.まとめ

Apr 7, 2020 · 4 min read