You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by yu...@apache.org on 2022/07/20 09:38:21 UTC

[rocketmq] 02/02: fix: unit test cases

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

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

commit d26ba7d433e05d7b3a518064c8ebf99c48df0bbd
Author: kaiyi.lk <ka...@alibaba-inc.com>
AuthorDate: Wed Jul 20 15:58:53 2022 +0800

    fix: unit test cases
---
 .../apache/rocketmq/proxy/grpc/v2/producer/SendMessageActivityTest.java | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/proxy/src/test/java/org/apache/rocketmq/proxy/grpc/v2/producer/SendMessageActivityTest.java b/proxy/src/test/java/org/apache/rocketmq/proxy/grpc/v2/producer/SendMessageActivityTest.java
index 7776d387e..117156b65 100644
--- a/proxy/src/test/java/org/apache/rocketmq/proxy/grpc/v2/producer/SendMessageActivityTest.java
+++ b/proxy/src/test/java/org/apache/rocketmq/proxy/grpc/v2/producer/SendMessageActivityTest.java
@@ -205,6 +205,8 @@ public class SendMessageActivityTest extends BaseActivityTest {
     @Test
     public void testBuildMessage() {
         long deliveryTime = System.currentTimeMillis() + TimeUnit.SECONDS.toMillis(5);
+        ConfigurationManager.getProxyConfig().setMessageDelayLevel("1s 5s");
+        ConfigurationManager.getProxyConfig().initData();
         String msgId = MessageClientIDSetter.createUniqID();
 
         org.apache.rocketmq.common.message.Message messageExt = this.sendMessageActivity.buildMessage(null,