fix test

apache · Jan 17, 2025 · 4700b83 · 4700b83
1 parent b2a5edb
commit 4700b83
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 22 deletions.
diff --git a/store/src/main/java/org/apache/rocketmq/store/timer/rocksdb/TimerMessageRocksDBStore.java b/store/src/main/java/org/apache/rocketmq/store/timer/rocksdb/TimerMessageRocksDBStore.java
@@ -726,24 +726,4 @@ public TimerMetrics getTimerMetrics() {
     public long getCommitOffset() {
         return commitOffset;
     }
-
-    public long getDequeueBehind() {
-        return 0;
-    }
-
-    public long getEnqueueBehindMessages() {
-        return 0;
-    }
-
-    public long getAllCongestNum() {
-        return 0;
-    }
-
-    public long getEnqueueTps() {
-        return 0;
-    }
-
-    public long getDequeueTps() {
-        return 0;
-    }
 }
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
@@ -265,7 +265,7 @@ public void testDeleteTimerMessage() throws Exception {
         timerMessageStore.load();
         timerMessageStore.start();
 
-        long delayMs = System.currentTimeMillis() + 1000;
+        long delayMs = System.currentTimeMillis() + 2000;
         String uniqKey = null;
         for (int i = 0; i < 5; i++) {
             MessageExtBrokerInner inner = buildMessage(delayMs, topic, false);
@@ -323,7 +323,6 @@ public void testPutDeleteTimerMessage() throws Exception {
         for (int i = 0; i < 5; i++) {
             ByteBuffer msgBuff = getOneMessage(topic, 0, i, 1000);
             assertNotNull(msgBuff);
-            // assertThat(System.currentTimeMillis()).isLessThan(delayMs + precisionMs);
         }
         assertNull(getOneMessage(topic, 0, 5, 1000));
 
@@ -332,6 +331,7 @@ public void testPutDeleteTimerMessage() throws Exception {
         MessageAccessor.putProperty(expiredInner, TimerMessageStore.TIMER_DELETE_UNIQUE_KEY, "XXX");
         PutMessageResult putMessageResult = transformTimerMessage(timerMessageStore, expiredInner);
         assertEquals(PutMessageStatus.WHEEL_TIMER_MSG_ILLEGAL, putMessageResult.getPutMessageStatus());
+        timerMessageStore.shutdown();
     }
 
     @Test