(rocketmq) branch develop updated: [ISSUE #9042] Update createTimerMessageStore call with new parameter (#9041)

[jinrongtong]

This is an automated email from the ASF dual-hosted git repository.

jinrongtong pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git


The following commit(s) were added to refs/heads/develop by this push:
     new 7da9ad4fa5 [ISSUE #9042] Update createTimerMessageStore call with new 
parameter (#9041)
7da9ad4fa5 is described below

commit 7da9ad4fa59da83f641a39bc8cd36233e3c7bb2d
Author: 小陈 <jamiechen....@gmail.com>
AuthorDate: Tue Dec 10 14:40:27 2024 +0800

    [ISSUE #9042] Update createTimerMessageStore call with new parameter (#9041)
    
    * Update createTimerMessageStore call with new parameter
    
    * Reduce unit test execution time
---
 .../java/org/apache/rocketmq/store/timer/TimerMessageStoreTest.java  | 5 ++---
 1 file changed, 2 insertions(+), 3 deletions(-)

diff --git 
a/store/src/test/java/org/apache/rocketmq/store/timer/TimerMessageStoreTest.java
 
b/store/src/test/java/org/apache/rocketmq/store/timer/TimerMessageStoreTest.java
index 36853bb44f..a014e77b90 100644
--- 
a/store/src/test/java/org/apache/rocketmq/store/timer/TimerMessageStoreTest.java
+++ 
b/store/src/test/java/org/apache/rocketmq/store/timer/TimerMessageStoreTest.java
@@ -259,8 +259,7 @@ public class TimerMessageStoreTest {
                 latch.countDown();
             }
         }).start();
-        latch.await(10, TimeUnit.SECONDS);
-
+        latch.await(5, TimeUnit.SECONDS);
         assertTrue(timerMessageStore.dequeuePutQueue.isEmpty());
         verify(mockMessageStore, 
times(6)).putMessage(any(MessageExtBrokerInner.class));
     }
@@ -379,7 +378,7 @@ public class TimerMessageStoreTest {
         String topic = "TimerTest_testDeleteTimerMessage";
         String collisionTopic = "TimerTest_testDeleteTimerMessage_collision";
 
-        TimerMessageStore timerMessageStore = createTimerMessageStore(null);
+        TimerMessageStore timerMessageStore = createTimerMessageStore(null , 
false);
         timerMessageStore.load();
         timerMessageStore.start(true);