This is an automated email from the ASF dual-hosted git repository.

duanzhengqiang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/shardingsphere.git


The following commit(s) were added to refs/heads/master by this push:
     new f0757e76dc3 Remove WorkerIdGenerator.parseWorkerId() (#19175)
f0757e76dc3 is described below

commit f0757e76dc387ca7b25c9f57642997a248a20287
Author: Liang Zhang <[email protected]>
AuthorDate: Fri Jul 15 10:08:17 2022 +0800

    Remove WorkerIdGenerator.parseWorkerId() (#19175)
---
 .../infra/instance/workerid/WorkerIdGenerator.java         | 14 --------------
 .../workerid/generator/StandaloneWorkerIdGenerator.java    |  7 ++++++-
 2 files changed, 6 insertions(+), 15 deletions(-)

diff --git 
a/shardingsphere-infra/shardingsphere-infra-common/src/main/java/org/apache/shardingsphere/infra/instance/workerid/WorkerIdGenerator.java
 
b/shardingsphere-infra/shardingsphere-infra-common/src/main/java/org/apache/shardingsphere/infra/instance/workerid/WorkerIdGenerator.java
index 274e28e09c9..5baa182d4af 100644
--- 
a/shardingsphere-infra/shardingsphere-infra-common/src/main/java/org/apache/shardingsphere/infra/instance/workerid/WorkerIdGenerator.java
+++ 
b/shardingsphere-infra/shardingsphere-infra-common/src/main/java/org/apache/shardingsphere/infra/instance/workerid/WorkerIdGenerator.java
@@ -37,18 +37,4 @@ public interface WorkerIdGenerator {
      * @return worker id
      */
     long generate(Properties props);
-    
-    /**
-     * Parse worker id.
-     *
-     * @param props props
-     * @return worker id
-     */
-    default long parseWorkerId(final Properties props) {
-        if (null == props) {
-            return DEFAULT_WORKER_ID;
-        }
-        Object workerId = props.get(WORKER_ID_KEY);
-        return null == workerId ? DEFAULT_WORKER_ID : 
Long.parseLong(workerId.toString());
-    }
 }
diff --git 
a/shardingsphere-mode/shardingsphere-mode-type/shardingsphere-standalone-mode/shardingsphere-standalone-mode-core/src/main/java/org/apache/shardingsphere/mode/manager/standalone/workerid/generator/StandaloneWorkerIdGenerator.java
 
b/shardingsphere-mode/shardingsphere-mode-type/shardingsphere-standalone-mode/shardingsphere-standalone-mode-core/src/main/java/org/apache/shardingsphere/mode/manager/standalone/workerid/generator/StandaloneWorkerIdGenerator.java
index 94487e92d1b..1dae2eaed12 100644
--- 
a/shardingsphere-mode/shardingsphere-mode-type/shardingsphere-standalone-mode/shardingsphere-standalone-mode-core/src/main/java/org/apache/shardingsphere/mode/manager/standalone/workerid/generator/StandaloneWorkerIdGenerator.java
+++ 
b/shardingsphere-mode/shardingsphere-mode-type/shardingsphere-standalone-mode/shardingsphere-standalone-mode-core/src/main/java/org/apache/shardingsphere/mode/manager/standalone/workerid/generator/StandaloneWorkerIdGenerator.java
@@ -28,6 +28,11 @@ public final class StandaloneWorkerIdGenerator implements 
WorkerIdGenerator {
     
     @Override
     public long generate(final Properties props) {
-        return parseWorkerId(props);
+        if (null == props) {
+            return DEFAULT_WORKER_ID;
+        }
+        Object workerId = props.get(WORKER_ID_KEY);
+        // TODO check can not exceed MAX_WORKER_ID
+        return null == workerId ? DEFAULT_WORKER_ID : 
Long.parseLong(workerId.toString());
     }
 }

Reply via email to