This is an automated email from the ASF dual-hosted git repository. jinrongtong pushed a commit to branch develop in repository https://gitbox.apache.org/repos/asf/rocketmq.git
The following commit(s) were added to refs/heads/develop by this push: new 6616600fa5 [ISSUE #7791] Polish the code for jraft controller 6616600fa5 is described below commit 6616600fa5e5f1426024ca9c40c12688c38edf9b Author: rongtong <jinrongto...@163.com> AuthorDate: Fri Feb 2 12:33:22 2024 +0800 [ISSUE #7791] Polish the code for jraft controller --- WORKSPACE | 2 +- .../java/org/apache/rocketmq/common/JraftConfig.java | 16 ++++++++-------- 2 files changed, 9 insertions(+), 9 deletions(-) diff --git a/WORKSPACE b/WORKSPACE index 5880f9ca47..16f66b7325 100644 --- a/WORKSPACE +++ b/WORKSPACE @@ -107,7 +107,7 @@ maven_install( "com.adobe.testing:s3mock-junit4:2.11.0", "io.github.aliyunmq:rocketmq-grpc-netty-codec-haproxy:1.0.0", "org.apache.rocketmq:rocketmq-rocksdb:1.0.2", - "com.alipay.sofa:jraft-core:1.3.11", + "com.alipay.sofa:jraft-core:1.3.14", "com.alipay.sofa:hessian:3.3.6", "io.netty:netty-tcnative-boringssl-static:2.0.48.Final", ], diff --git a/common/src/main/java/org/apache/rocketmq/common/JraftConfig.java b/common/src/main/java/org/apache/rocketmq/common/JraftConfig.java index 1bb3bf0298..072d0caf24 100644 --- a/common/src/main/java/org/apache/rocketmq/common/JraftConfig.java +++ b/common/src/main/java/org/apache/rocketmq/common/JraftConfig.java @@ -17,14 +17,14 @@ package org.apache.rocketmq.common; public class JraftConfig { - int jRaftElectionTimeoutMs = 1000; - - int jRaftScanWaitTimeoutMs = 1000; - int jRaftSnapshotIntervalSecs = 3600; - String jRaftGroupId = "jRaft-Controller"; - String jRaftServerId = "localhost:9880"; - String jRaftInitConf = "localhost:9880,localhost:9881,localhost:9882"; - String jRaftControllerRPCAddr = "localhost:9770,localhost:9771,localhost:9772"; + private int jRaftElectionTimeoutMs = 1000; + + private int jRaftScanWaitTimeoutMs = 1000; + private int jRaftSnapshotIntervalSecs = 3600; + private String jRaftGroupId = "jRaft-Controller"; + private String jRaftServerId = "localhost:9880"; + private String jRaftInitConf = "localhost:9880,localhost:9881,localhost:9882"; + private String jRaftControllerRPCAddr = "localhost:9770,localhost:9771,localhost:9772"; public int getjRaftElectionTimeoutMs() { return jRaftElectionTimeoutMs;