Change Raft 1.4.0 to 1.8.0

wenweihu86 · Oct 25, 2018 · e8676db · e8676db
1 parent a2bf76f
commit e8676db
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 5 deletions.
diff --git a/distmq-broker/pom.xml b/distmq-broker/pom.xml
@@ -106,7 +106,7 @@
         <dependency>
             <groupId>com.github.wenweihu86.raft</groupId>
             <artifactId>raft-java-core</artifactId>
-            <version>1.4.0</version>
+            <version>1.8.0</version>
         </dependency>
         <dependency>
             <groupId>commons-io</groupId>
@@ -121,7 +121,7 @@
         <dependency>
             <groupId>com.github.wenweihu86.distmq</groupId>
             <artifactId>distmq-client</artifactId>
-            <version>1.0.0-SNAPSHOT</version>
+            <version>1.0.0</version>
         </dependency>
         <dependency>
             <groupId>junit</groupId>

diff --git a/distmq-broker/src/main/java/com/github/wenweihu86/distmq/broker/BrokerMain.java b/distmq-broker/src/main/java/com/github/wenweihu86/distmq/broker/BrokerMain.java
@@ -36,13 +36,14 @@ public static void main(String[] args) {
         // 应用状态机
         BrokerStateMachine stateMachine = new BrokerStateMachine(dataDir);
         // 设置数据目录
-        RaftOptions.dataDir = dataDir;
+        RaftOptions raftOptions = new RaftOptions();
+        raftOptions.setDataDir(dataDir);
 //        // just for test snapshot
 //        RaftOptions.snapshotMinLogSize = 10 * 1024;
 //        RaftOptions.snapshotPeriodSeconds = 30;
 //        RaftOptions.maxSegmentFileSize = 1024 * 1024;
         // 初始化RaftNode
-        RaftNode raftNode = new RaftNode(servers, localServer, stateMachine);
+        RaftNode raftNode = new RaftNode(raftOptions, servers, localServer, stateMachine);
         stateMachine.setRaftNode(raftNode);
         // 注册Raft节点之间相互调用的服务
         RaftConsensusService raftConsensusService = new RaftConsensusServiceImpl(raftNode);

diff --git a/distmq-example/pom.xml b/distmq-example/pom.xml
@@ -43,7 +43,7 @@
         <dependency>
             <groupId>com.github.wenweihu86.distmq</groupId>
             <artifactId>distmq-client</artifactId>
-            <version>1.0.0-SNAPSHOT</version>
+            <version>1.0.0</version>
         </dependency>
         <dependency>
             <groupId>junit</groupId>