revert

apache · Sep 3, 2024 · f8c12d3 · f8c12d3
1 parent 3c3945c
commit f8c12d3
Showing 1 changed file with 0 additions and 7 deletions.
diff --git a/store/src/test/java/org/apache/rocketmq/store/dledger/MessageStoreTestBase.java b/store/src/test/java/org/apache/rocketmq/store/dledger/MessageStoreTestBase.java
@@ -16,7 +16,6 @@
  */
 package org.apache.rocketmq.store.dledger;
 
-import com.google.common.util.concurrent.RateLimiter;
 import io.openmessaging.storage.dledger.DLedgerConfig;
 import io.openmessaging.storage.dledger.DLedgerServer;
 import java.io.File;
@@ -123,13 +122,7 @@ protected DefaultMessageStore createMessageStore(String base, boolean createAbor
     }
 
     protected void doPutMessages(MessageStore messageStore, String topic, int queueId, int num, long beginLogicsOffset) throws UnknownHostException {
-        RateLimiter rateLimiter = RateLimiter.create(100);
-        MessageStoreConfig storeConfig = messageStore.getMessageStoreConfig();
-        boolean limitAppendRate = storeConfig.isEnableDLegerCommitLog();
         for (int i = 0; i < num; i++) {
-            if (limitAppendRate) {
-                rateLimiter.acquire();
-            }
             MessageExtBrokerInner msgInner = buildMessage();
             msgInner.setTopic(topic);
             msgInner.setQueueId(queueId);