fix test style

scwlkq · Mar 9, 2024 · 6561d69 · 6561d69
1 parent 6d4a283
commit 6561d69
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 4 deletions.
diff --git a/...shboard/console/function/health/check/impl/storage/rocketmq4/RocketmqBrokerCheckTest.java b/...shboard/console/function/health/check/impl/storage/rocketmq4/RocketmqBrokerCheckTest.java
@@ -35,7 +35,7 @@ class RocketmqBrokerCheckTest {
     @BeforeEach
     public void init() {
         HealthCheckObjectConfig config = new HealthCheckObjectConfig();
-        config.getRocketmqConfig().setBrokerUrl("127.0.0.1:10911");
+        config.getRocketmqProperties().setBrokerUrl("127.0.0.1:10911");
         config.setRequestTimeoutMillis(1000L);
         rocketmqCheck = new Rocketmq4BrokerCheck(config);
     }

diff --git a/...ard/console/function/health/check/impl/storage/rocketmq4/RocketmqNameserverCheckTest.java b/...ard/console/function/health/check/impl/storage/rocketmq4/RocketmqNameserverCheckTest.java
@@ -35,7 +35,7 @@ class RocketmqNameserverCheckTest {
     @BeforeEach
     public void init() {
         HealthCheckObjectConfig config = new HealthCheckObjectConfig();
-        config.getRocketmqConfig().setNameServerUrl("127.0.0.1:9876");
+        config.getRocketmqProperties().setNamesrvAddr("127.0.0.1:9876");
         config.setRequestTimeoutMillis(1000L);
         rocketmqCheck = new Rocketmq4NameServerCheck(config);
     }

diff --git a/...ashboard/console/function/health/check/impl/storage/rocketmq4/RocketmqTopicCheckTest.java b/...ashboard/console/function/health/check/impl/storage/rocketmq4/RocketmqTopicCheckTest.java
@@ -35,8 +35,8 @@ class RocketmqTopicCheckTest {
     @BeforeEach
     public void init() throws InterruptedException {
         HealthCheckObjectConfig config = new HealthCheckObjectConfig();
-        config.getRocketmqConfig().setBrokerUrl("127.0.0.1:10911");
-        config.getRocketmqConfig().setNameServerUrl("127.0.0.1:9876");
+        config.getRocketmqProperties().setBrokerUrl("127.0.0.1:10911");
+        config.getRocketmqProperties().setNamesrvAddr("127.0.0.1:9876");
         config.setRequestTimeoutMillis(1000000L);
         rocketmqCheck = new Rocketmq4TopicCheck(config);
     }