fix: fix the consumer of order and simple param test

Signed-off-by: wangxye <[email protected]>
AutoMQ · Nov 14, 2023 · 8369df4 · 8369df4
1 parent 1cda952
commit 8369df4
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 3 deletions.
diff --git a/java/e2e/src/test/java/org/apache/rocketmq/broker/server/OrderMessageTest.java b/java/e2e/src/test/java/org/apache/rocketmq/broker/server/OrderMessageTest.java
@@ -100,7 +100,6 @@ public void testOrder_Send_PushConsumeOrderly() {
         Assertions.assertEquals(SEND_NUM, producer.getEnqueueMessages().getDataSize(), "send message failed");
 //        DataCollector<Object> dequeueMessages = simpleConsumer.getListener().getDequeueMessages();
 //        dequeueMessages.addData(pushConsumer.getListener().getDequeueMessages());
-
         VerifyUtils.verifyOrderMessage(producer.getEnqueueMessages(), pushConsumer.getListener().getDequeueMessages());
     }
 

diff --git a/java/e2e/src/test/java/org/apache/rocketmq/broker/simple/SimpleParamTest.java b/java/e2e/src/test/java/org/apache/rocketmq/broker/simple/SimpleParamTest.java
@@ -123,11 +123,11 @@ public void test_waitAckException_reReceive_ack() {
         Message message = MessageFactory.buildMessage(topic, tag, RandomUtils.getStringByUUID());
         producer.send(message);
         Assertions.assertEquals(1, producer.getEnqueueMessages().getDataSize(), "send message failed");
-
+        TestUtils.waitForSeconds(1);
         try {
             long startTime = System.currentTimeMillis();
             while (System.currentTimeMillis() < startTime + 60000) {
-                List<MessageView> messageViews = consumer.receive(1, Duration.ofSeconds(10));
+                List<MessageView> messageViews = consumer.receive(1, Duration.ofSeconds(5));
                 if (messageViews.size() > 0) {
                     for (MessageView messageView : messageViews) {
                         log.info("MessageId:{}, Body:{}, tag:{}, property:{}", messageView.getMessageId(), StandardCharsets.UTF_8.decode(messageView.getBody()).toString(), messageView.getTag().get(), messageView.getProperties());