fix fail test

apache · Jan 20, 2025 · 2741799 · 2741799
1 parent 5a675f9
commit 2741799
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/...e/src/test/java/org/apache/rocketmq/store/timer/rocksdb/TimerMessageRocksDBStoreTest.java b/...e/src/test/java/org/apache/rocketmq/store/timer/rocksdb/TimerMessageRocksDBStoreTest.java
@@ -282,10 +282,10 @@ public void testDeleteTimerMessage() throws Exception {
         assertEquals(PutMessageStatus.PUT_OK, messageStore.putMessage(delMsg).getPutMessageStatus());
 
         // The first one should have been deleted.
-        for (int i = 1; i < 4; i++) {
-            ByteBuffer msgBuff = getOneMessage(topic, 0, i, 3000);
-            assertNotNull(msgBuff);
-            MessageExt msgExt = MessageDecoder.decode(msgBuff);
+        for (int i = 0; i < 4; i++) {
+            ByteBuffer msgBuff1 = getOneMessage(topic, 0, i, 3000);
+            assertNotNull(msgBuff1);
+            MessageExt msgExt = MessageDecoder.decode(msgBuff1);
             assertNotNull(msgExt);
         }
         // The last one should be null.