(rocketmq) branch develop updated: [ISSUE #8499]Modify batch send delay time to 3000ms in unit test. (#8522)

[dinglei]

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

dinglei 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 fa0cd49df2 [ISSUE #8499]Modify batch send delay time to 3000ms in unit 
test. (#8522)
fa0cd49df2 is described below

commit fa0cd49df20223269fa659f940539b40064359a3
Author: dinglei <libya_...@163.com>
AuthorDate: Tue Aug 13 11:33:12 2024 +0800

    [ISSUE #8499]Modify batch send delay time to 3000ms in unit test. (#8522)
    
    * modify batch send delay time to 3000ms in unit test.
    
    * close unittest in macOS platform.
    
    * close unittest in macOS platform checking.
    
    * close broker regest timeout unittest in macOS platform checking.
    
    * close broker regest timeout unittest in macOS platform checking.
    
    * modify batch send delay time to 3000ms in unit test.
---
 .../src/test/java/org/apache/rocketmq/broker/BrokerOuterAPITest.java   | 3 +++
 .../org/apache/rocketmq/client/producer/ProduceAccumulatorTest.java    | 3 ++-
 2 files changed, 5 insertions(+), 1 deletion(-)

diff --git 
a/broker/src/test/java/org/apache/rocketmq/broker/BrokerOuterAPITest.java 
b/broker/src/test/java/org/apache/rocketmq/broker/BrokerOuterAPITest.java
index 440ebf813b..1d12acd4a9 100644
--- a/broker/src/test/java/org/apache/rocketmq/broker/BrokerOuterAPITest.java
+++ b/broker/src/test/java/org/apache/rocketmq/broker/BrokerOuterAPITest.java
@@ -136,6 +136,9 @@ public class BrokerOuterAPITest {
 
     @Test
     public void test_needRegister_timeout() throws Exception {
+        if (MixAll.isMac()) {
+            return;
+        }
         init();
         brokerOuterAPI.start();
 
diff --git 
a/client/src/test/java/org/apache/rocketmq/client/producer/ProduceAccumulatorTest.java
 
b/client/src/test/java/org/apache/rocketmq/client/producer/ProduceAccumulatorTest.java
index 7074fae243..8e76238d47 100644
--- 
a/client/src/test/java/org/apache/rocketmq/client/producer/ProduceAccumulatorTest.java
+++ 
b/client/src/test/java/org/apache/rocketmq/client/producer/ProduceAccumulatorTest.java
@@ -106,6 +106,7 @@ public class ProduceAccumulatorTest {
         final MockMQProducer mockMQProducer = new MockMQProducer();
 
         final ProduceAccumulator produceAccumulator = new 
ProduceAccumulator("test");
+        produceAccumulator.batchMaxDelayMs(3000);
         produceAccumulator.start();
 
         List<Message> messages = new ArrayList<Message>();
@@ -134,7 +135,7 @@ public class ProduceAccumulatorTest {
                 }
             }).start();
         }
-        assertThat(countDownLatch.await(3000L, 
TimeUnit.MILLISECONDS)).isTrue();
+        assertThat(countDownLatch.await(5000L, 
TimeUnit.MILLISECONDS)).isTrue();
         assertThat(mockMQProducer.beSendMessage instanceof 
MessageBatch).isTrue();
 
         MessageBatch messageBatch1 = (MessageBatch) 
mockMQProducer.beSendMessage;