public void add(SessionContext sctx, String cluster, String serverName) {
log.debug("server register rpc client cluster[{}] serverName[{}] sessionContext[{}]", cluster, serverName, sctx);
RpcClientCluster clientCluster = nameToCluster.get(cluster);
if (clientCluster == null) {
clientCluster = new RpcClientCluster();
clientCluster.addClient(serverName, new RpcClientGroup());
nameToCluster.put(cluster, clientCluster);
}
clientCluster.getRpcClientGroup(serverName).addClient(sctx);
}
public void add(SessionContext sctx, String cluster, String serverName) {
log.debug("server register rpc client cluster[{}] serverName[{}] sessionContext[{}]", new Object[]{cluster, serverName, sctx});
RpcClientCluster clientCluster = (RpcClientCluster)this.nameToCluster.get(cluster);
if (clientCluster == null) {
clientCluster = new RpcClientCluster();
this.nameToCluster.put(cluster, clientCluster);
}
RpcClientGroup rcg = clientCluster.getRpcClientGroup(serverName);
if (rcg == null) {
rcg = new RpcClientGroup();
clientCluster.addClient(serverName, rcg);
}
rcg.addClient(sctx);
}