Use io.openmessaging instead

broker/src/main/java/org/apache/rocketmq/broker/dleger/DLegerRoleChangeHandler.java

@@ -21,10 +21,10 @@ import java.util.concurrent.Executors;
 import org.apache.rocketmq.broker.BrokerController;
 import org.apache.rocketmq.common.ThreadFactoryImpl;
 import org.apache.rocketmq.common.constant.LoggerName;
-import org.apache.rocketmq.dleger.DLegerLeaderElector;
-import org.apache.rocketmq.dleger.DLegerServer;
-import org.apache.rocketmq.dleger.MemberState;
-import org.apache.rocketmq.dleger.utils.UtilAll;
+import io.openmessaging.storage.dleger.DLegerLeaderElector;
+import io.openmessaging.storage.dleger.DLegerServer;
+import io.openmessaging.storage.dleger.MemberState;
+import io.openmessaging.storage.dleger.utils.UtilAll;
 import org.apache.rocketmq.logging.InternalLogger;
 import org.apache.rocketmq.logging.InternalLoggerFactory;
 import org.apache.rocketmq.store.DefaultMessageStore;

store/pom.xml

@@ -29,8 +29,8 @@
 
     <dependencies>
         <dependency>
-            <groupId>org.apache.rocketmq</groupId>
-            <artifactId>rocketmq-dleger</artifactId>
+            <groupId>io.openmessaging.storage</groupId>
+            <artifactId>dleger</artifactId>
             <version>0.1-SNAPSHOT</version>
             <exclusions>
                 <exclusion>

store/src/main/java/org/apache/rocketmq/store/dleger/DLegerCommitLog.java

@@ -16,6 +16,16 @@
  */
 package org.apache.rocketmq.store.dleger;
 
+import io.openmessaging.storage.dleger.DLegerConfig;
+import io.openmessaging.storage.dleger.DLegerServer;
+import io.openmessaging.storage.dleger.entry.DLegerEntry;
+import io.openmessaging.storage.dleger.protocol.AppendEntryRequest;
+import io.openmessaging.storage.dleger.protocol.AppendEntryResponse;
+import io.openmessaging.storage.dleger.protocol.DLegerResponseCode;
+import io.openmessaging.storage.dleger.store.file.DLegerMmapFileStore;
+import io.openmessaging.storage.dleger.store.file.MmapFile;
+import io.openmessaging.storage.dleger.store.file.MmapFileList;
+import io.openmessaging.storage.dleger.store.file.SelectMmapBufferResult;
 import java.nio.ByteBuffer;
 import java.util.HashMap;
 import java.util.concurrent.CompletableFuture;
@@ -27,16 +37,6 @@ import org.apache.rocketmq.common.message.MessageDecoder;
 import org.apache.rocketmq.common.message.MessageExt;
 import org.apache.rocketmq.common.message.MessageExtBatch;
 import org.apache.rocketmq.common.sysflag.MessageSysFlag;
-import org.apache.rocketmq.dleger.DLegerConfig;
-import org.apache.rocketmq.dleger.DLegerServer;
-import org.apache.rocketmq.dleger.entry.DLegerEntry;
-import org.apache.rocketmq.dleger.protocol.AppendEntryRequest;
-import org.apache.rocketmq.dleger.protocol.AppendEntryResponse;
-import org.apache.rocketmq.dleger.protocol.DLegerResponseCode;
-import org.apache.rocketmq.dleger.store.file.DLegerMmapFileStore;
-import org.apache.rocketmq.dleger.store.file.MmapFile;
-import org.apache.rocketmq.dleger.store.file.MmapFileList;
-import org.apache.rocketmq.dleger.store.file.SelectMmapBufferResult;
 import org.apache.rocketmq.store.AppendMessageResult;
 import org.apache.rocketmq.store.AppendMessageStatus;
 import org.apache.rocketmq.store.CommitLog;

store/src/main/java/org/apache/rocketmq/store/dleger/DLegerSelectMappedBufferResult.java

@@ -17,7 +17,7 @@
 
 package org.apache.rocketmq.store.dleger;
 
-import org.apache.rocketmq.dleger.store.file.SelectMmapBufferResult;
+import io.openmessaging.storage.dleger.store.file.SelectMmapBufferResult;
 import org.apache.rocketmq.store.SelectMappedBufferResult;
 
 public class DLegerSelectMappedBufferResult extends SelectMappedBufferResult {

store/src/test/java/org/apache/rocketmq/store/dleger/DLegerCommitlogTest.java

@@ -8,7 +8,7 @@ import java.util.UUID;
 import org.apache.rocketmq.common.BrokerConfig;
 import org.apache.rocketmq.common.message.MessageDecoder;
 import org.apache.rocketmq.common.message.MessageExt;
-import org.apache.rocketmq.dleger.DLegerServer;
+import io.openmessaging.storage.dleger.DLegerServer;
 import org.apache.rocketmq.store.DefaultMessageStore;
 import org.apache.rocketmq.store.GetMessageResult;
 import org.apache.rocketmq.store.GetMessageStatus;