diff --git a/eventmesh-dashboard-console/src/test/java/org/apache/eventmesh/dashboard/console/function/health/check/impl/storage/rocketmq4/RocketmqBrokerCheckTest.java b/eventmesh-dashboard-console/src/test/java/org/apache/eventmesh/dashboard/console/function/health/check/impl/storage/rocketmq4/RocketmqBrokerCheckTest.java index abf7ab29..012717f2 100644 --- a/eventmesh-dashboard-console/src/test/java/org/apache/eventmesh/dashboard/console/function/health/check/impl/storage/rocketmq4/RocketmqBrokerCheckTest.java +++ b/eventmesh-dashboard-console/src/test/java/org/apache/eventmesh/dashboard/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/eventmesh-dashboard-console/src/test/java/org/apache/eventmesh/dashboard/console/function/health/check/impl/storage/rocketmq4/RocketmqNameserverCheckTest.java b/eventmesh-dashboard-console/src/test/java/org/apache/eventmesh/dashboard/console/function/health/check/impl/storage/rocketmq4/RocketmqNameserverCheckTest.java index 92677bae..ba057bb8 100644 --- a/eventmesh-dashboard-console/src/test/java/org/apache/eventmesh/dashboard/console/function/health/check/impl/storage/rocketmq4/RocketmqNameserverCheckTest.java +++ b/eventmesh-dashboard-console/src/test/java/org/apache/eventmesh/dashboard/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/eventmesh-dashboard-console/src/test/java/org/apache/eventmesh/dashboard/console/function/health/check/impl/storage/rocketmq4/RocketmqTopicCheckTest.java b/eventmesh-dashboard-console/src/test/java/org/apache/eventmesh/dashboard/console/function/health/check/impl/storage/rocketmq4/RocketmqTopicCheckTest.java index 8a90a5bd..c812feba 100644 --- a/eventmesh-dashboard-console/src/test/java/org/apache/eventmesh/dashboard/console/function/health/check/impl/storage/rocketmq4/RocketmqTopicCheckTest.java +++ b/eventmesh-dashboard-console/src/test/java/org/apache/eventmesh/dashboard/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); }