From 6561d692dc1a6a2bd3d8de3c89b6276b20c7d22c Mon Sep 17 00:00:00 2001 From: scwlkq Date: Sun, 10 Mar 2024 00:08:43 +0800 Subject: [PATCH] fix test style --- .../check/impl/storage/rocketmq4/RocketmqBrokerCheckTest.java | 2 +- .../impl/storage/rocketmq4/RocketmqNameserverCheckTest.java | 2 +- .../check/impl/storage/rocketmq4/RocketmqTopicCheckTest.java | 4 ++-- 3 files changed, 4 insertions(+), 4 deletions(-) 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); }