From 083bf981f33fd9f2eedd09cc52dd70b45ff46638 Mon Sep 17 00:00:00 2001 From: wangxye Date: Mon, 13 Nov 2023 18:05:24 +0800 Subject: [PATCH] fix: support delay message test in grpc e2e Signed-off-by: wangxye --- .../org/apache/rocketmq/broker/server/DelayMessageTest.java | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/java/e2e/src/test/java/org/apache/rocketmq/broker/server/DelayMessageTest.java b/java/e2e/src/test/java/org/apache/rocketmq/broker/server/DelayMessageTest.java index 56a7761..51d2949 100644 --- a/java/e2e/src/test/java/org/apache/rocketmq/broker/server/DelayMessageTest.java +++ b/java/e2e/src/test/java/org/apache/rocketmq/broker/server/DelayMessageTest.java @@ -45,7 +45,6 @@ import org.slf4j.Logger; import org.slf4j.LoggerFactory; -import java.time.Duration; import java.util.concurrent.Callable; import static java.util.concurrent.TimeUnit.SECONDS; @@ -101,7 +100,7 @@ public void testDelay_Send_PushConsume() { producer.send(message); } Assertions.assertEquals(SEND_NUM, producer.getEnqueueMessages().getDataSize(), "send message failed"); - VerifyUtils.verifyDelayMessage(producer.getEnqueueMessages(), pushConsumer.getListener().getDequeueMessages(), 20); + VerifyUtils.verifyDelayMessage(producer.getEnqueueMessages(), pushConsumer.getListener().getDequeueMessages(), 10); } @Test @@ -129,7 +128,7 @@ public Boolean call() throws Exception { } }); Assertions.assertEquals(SEND_NUM, producer.getEnqueueMessages().getDataSize(), "send message failed"); - VerifyUtils.verifyDelayMessage(producer.getEnqueueMessages(), pushConsumer.getListener().getDequeueMessages(), 20); + VerifyUtils.verifyDelayMessage(producer.getEnqueueMessages(), pushConsumer.getListener().getDequeueMessages(), 10); } @Test