Optimize and update some code

apache · Feb 8, 2021 · b6664c5 · b6664c5
1 parent d3bf39c
commit b6664c5
Show file tree

Hide file tree

Showing 4 changed files with 9 additions and 8 deletions.
diff --git a/hugegraph-api/src/main/java/com/baidu/hugegraph/rpc/RpcClientProvider.java b/hugegraph-api/src/main/java/com/baidu/hugegraph/rpc/RpcClientProvider.java
@@ -38,7 +38,7 @@ public UserManager userManager() {
     }
 
     public Object serviceProxy(String serviceName) {
-        ConsumerConfig config = rpcConsumerConfig.consumerConfig(serviceName);
+        ConsumerConfig config = this.rpcConsumerConfig.consumerConfig(serviceName);
         return config.refer();
     }
 }
diff --git a/hugegraph-api/src/main/java/com/baidu/hugegraph/rpc/RpcConsumerConfig.java b/hugegraph-api/src/main/java/com/baidu/hugegraph/rpc/RpcConsumerConfig.java
@@ -41,13 +41,13 @@ public <T> void addConsumerConfig(Class<T> clazz, HugeConfig conf) {
                 .setRetries(conf.get(ServerOptions.RPC_CLIENT_RETRIES))
                 .setLoadBalancer(conf.get(
                                  ServerOptions.RPC_CLIENT_LOAD_BALANCER));
-        configs.put(clazz.getName(), consumerConfig);
+        this.configs.put(clazz.getName(), consumerConfig);
     }
 
     public ConsumerConfig consumerConfig(String serverName) {
-        if (!configs.containsKey(serverName)) {
+        if (!this.configs.containsKey(serverName)) {
             throw new RpcException("Invalid server name '%s'", serverName);
         }
-        return configs.get(serverName);
+        return this.configs.get(serverName);
     }
 }
diff --git a/hugegraph-api/src/main/java/com/baidu/hugegraph/rpc/RpcProviderConfig.java b/hugegraph-api/src/main/java/com/baidu/hugegraph/rpc/RpcProviderConfig.java
@@ -33,10 +33,10 @@ public <T, E extends T> void addProviderConfig(Class<T> clazz,
         ProviderConfig<T> providerConfig = new ProviderConfig<T>()
                                            .setInterfaceId(clazz.getName())
                                            .setRef(serviceImpl);
-        configs.put(clazz.getName(), providerConfig);
+        this.configs.put(clazz.getName(), providerConfig);
     }
 
     public Map<String, ProviderConfig> providerConfigs() {
-        return configs;
+        return this.configs;
     }
 }
diff --git a/hugegraph-api/src/main/java/com/baidu/hugegraph/rpc/SofaRpcServer.java b/hugegraph-api/src/main/java/com/baidu/hugegraph/rpc/SofaRpcServer.java
@@ -58,7 +58,8 @@ public SofaRpcServer(HugeConfig conf, RpcProviderConfig providerConfig) {
 
     public void exportAll() {
         if (MapUtils.isEmpty(this.providerConfigs)) {
-            throw new RpcException("Server provider config map is empty");
+            throw new RpcException("The server provider config map can't be " +
+                                   "empty");
         }
         for (ProviderConfig providerConfig : this.providerConfigs.values()) {
             providerConfig.setServer(this.serverConfig);
@@ -68,7 +69,7 @@ public void exportAll() {
 
     public void unExport(String serviceName) {
         if (!this.providerConfigs.containsKey(serviceName)) {
-            throw new RpcException("Service name '%s' is not exist, please " +
+            throw new RpcException("The service name '%s' doesn't exist, please " +
                                    "change others", serviceName);
         }
         this.providerConfigs.get(serviceName).unExport();