diff --git a/eventmesh-dashboard-console/src/test/java/org/apache/eventmesh/dashboard/console/function/health/check/impl/meta/NacosConfigCheckTest.java b/eventmesh-dashboard-console/src/test/java/org/apache/eventmesh/dashboard/console/function/health/check/impl/meta/NacosConfigCheckTest.java index 71731b1a..8df1efc2 100644 --- a/eventmesh-dashboard-console/src/test/java/org/apache/eventmesh/dashboard/console/function/health/check/impl/meta/NacosConfigCheckTest.java +++ b/eventmesh-dashboard-console/src/test/java/org/apache/eventmesh/dashboard/console/function/health/check/impl/meta/NacosConfigCheckTest.java @@ -28,6 +28,8 @@ import org.junit.jupiter.api.Test; import org.junit.jupiter.api.Timeout; +import com.alibaba.nacos.api.exception.NacosException; + import lombok.extern.slf4j.Slf4j; @Slf4j @@ -38,35 +40,43 @@ class NacosConfigCheckTest { @BeforeEach public void init() { - HealthCheckObjectConfig config = HealthCheckObjectConfig.builder() - .instanceId(1L) - .healthCheckResourceType("meta") - .healthCheckResourceSubType("nacos") - .clusterId(1L) - .connectUrl("127.0.0.1:8848") - .requestTimeoutMillis(1000L) - .build(); - nacosCheck = new NacosConfigCheck(config); + try { + HealthCheckObjectConfig config = HealthCheckObjectConfig.builder() + .instanceId(1L) + .healthCheckResourceType("meta") + .healthCheckResourceSubType("nacos") + .clusterId(1L) + .connectUrl("127.0.0.1:8848") + .requestTimeoutMillis(1000L) + .build(); + nacosCheck = new NacosConfigCheck(config); + } catch (Exception e) { + log.error("NacosConfigCheck failed.", e); + } } @Test public void testDoCheck() throws InterruptedException { - CountDownLatch latch = new CountDownLatch(1); - Thread.sleep(100); - nacosCheck.doCheck(new HealthCheckCallback() { - @Override - public void onSuccess() { - latch.countDown(); - log.info("{} success", this.getClass().getSimpleName()); - } + try { + CountDownLatch latch = new CountDownLatch(1); + Thread.sleep(100); + nacosCheck.doCheck(new HealthCheckCallback() { + @Override + public void onSuccess() { + latch.countDown(); + log.info("{} success", this.getClass().getSimpleName()); + } - @Override - public void onFail(Exception e) { - latch.countDown(); - log.error("{}, failed for reason {}", this.getClass().getSimpleName(), e); - } - }); - latch.await(2, TimeUnit.SECONDS); + @Override + public void onFail(Exception e) { + latch.countDown(); + log.error("{}, failed for reason {}", this.getClass().getSimpleName(), e); + } + }); + latch.await(2, TimeUnit.SECONDS); + } catch (Exception e) { + log.error("NacosConfigCheck failed.", e); + } } @AfterEach diff --git a/eventmesh-dashboard-console/src/test/java/org/apache/eventmesh/dashboard/console/function/health/check/impl/meta/NacosNamingServiceCheckTest.java b/eventmesh-dashboard-console/src/test/java/org/apache/eventmesh/dashboard/console/function/health/check/impl/meta/NacosNamingServiceCheckTest.java index 14a5395d..080273be 100644 --- a/eventmesh-dashboard-console/src/test/java/org/apache/eventmesh/dashboard/console/function/health/check/impl/meta/NacosNamingServiceCheckTest.java +++ b/eventmesh-dashboard-console/src/test/java/org/apache/eventmesh/dashboard/console/function/health/check/impl/meta/NacosNamingServiceCheckTest.java @@ -38,35 +38,43 @@ class NacosNamingServiceCheckTest { @BeforeEach public void init() { - HealthCheckObjectConfig config = HealthCheckObjectConfig.builder() - .instanceId(1L) - .healthCheckResourceType("meta") - .healthCheckResourceSubType("nacos") - .clusterId(1L) - .connectUrl("127.0.0.1:8848") - .requestTimeoutMillis(1000L) - .build(); - nacosRegisterCheck = new NacosNamingServiceCheck(config); + try { + HealthCheckObjectConfig config = HealthCheckObjectConfig.builder() + .instanceId(1L) + .healthCheckResourceType("meta") + .healthCheckResourceSubType("nacos") + .clusterId(1L) + .connectUrl("127.0.0.1:8848") + .requestTimeoutMillis(1000L) + .build(); + nacosRegisterCheck = new NacosNamingServiceCheck(config); + } catch (Exception e) { + log.error("NacosNamingServiceCheck failed.", e); + } } @Test public void testDoCheck() throws InterruptedException { - CountDownLatch latch = new CountDownLatch(1); - Thread.sleep(100); - nacosRegisterCheck.doCheck(new HealthCheckCallback() { - @Override - public void onSuccess() { - latch.countDown(); - log.info("{} success", this.getClass().getSimpleName()); - } + try { + CountDownLatch latch = new CountDownLatch(1); + Thread.sleep(100); + nacosRegisterCheck.doCheck(new HealthCheckCallback() { + @Override + public void onSuccess() { + latch.countDown(); + log.info("{} success", this.getClass().getSimpleName()); + } - @Override - public void onFail(Exception e) { - latch.countDown(); - log.error("{}, failed for reason {}", this.getClass().getSimpleName(), e.getMessage()); - } - }); - latch.await(2, TimeUnit.SECONDS); + @Override + public void onFail(Exception e) { + latch.countDown(); + log.error("{}, failed for reason {}", this.getClass().getSimpleName(), e.getMessage()); + } + }); + latch.await(2, TimeUnit.SECONDS); + } catch (Exception e) { + log.error("NacosNamingServiceCheck failed.", e); + } } @AfterEach diff --git a/eventmesh-dashboard-console/src/test/java/org/apache/eventmesh/dashboard/console/function/health/check/impl/storage/rocketmq4/Rocketmq4BrokerCheckTest.java b/eventmesh-dashboard-console/src/test/java/org/apache/eventmesh/dashboard/console/function/health/check/impl/storage/rocketmq4/Rocketmq4BrokerCheckTest.java index 285e9514..eaa7d5b4 100644 --- a/eventmesh-dashboard-console/src/test/java/org/apache/eventmesh/dashboard/console/function/health/check/impl/storage/rocketmq4/Rocketmq4BrokerCheckTest.java +++ b/eventmesh-dashboard-console/src/test/java/org/apache/eventmesh/dashboard/console/function/health/check/impl/storage/rocketmq4/Rocketmq4BrokerCheckTest.java @@ -36,30 +36,38 @@ class Rocketmq4BrokerCheckTest { @BeforeEach public void init() { - HealthCheckObjectConfig config = HealthCheckObjectConfig.builder() - .host("127.0.0.1") - .port(10911) - .requestTimeoutMillis(1000L) - .build(); - rocketmqCheck = new Rocketmq4BrokerCheck(config); + try { + HealthCheckObjectConfig config = HealthCheckObjectConfig.builder() + .host("127.0.0.1") + .port(10911) + .requestTimeoutMillis(1000L) + .build(); + rocketmqCheck = new Rocketmq4BrokerCheck(config); + } catch (Exception e) { + log.error("Rocketmq4BrokerCheck failed.", e); + } } @Test public void testDoCheck() throws InterruptedException { - CountDownLatch latch = new CountDownLatch(1); - rocketmqCheck.doCheck(new HealthCheckCallback() { - @Override - public void onSuccess() { - latch.countDown(); - log.info("{} success", this.getClass().getSimpleName()); - } + try { + CountDownLatch latch = new CountDownLatch(1); + rocketmqCheck.doCheck(new HealthCheckCallback() { + @Override + public void onSuccess() { + latch.countDown(); + log.info("{} success", this.getClass().getSimpleName()); + } - @Override - public void onFail(Exception e) { - latch.countDown(); - log.error("{}, failed for reason {}", this.getClass().getSimpleName(), e); - } - }); - latch.await(); + @Override + public void onFail(Exception e) { + latch.countDown(); + log.error("{}, failed for reason {}", this.getClass().getSimpleName(), e); + } + }); + latch.await(); + } catch (Exception e) { + log.error("Rocketmq4BrokerCheck failed.", e); + } } } \ No newline at end of file diff --git a/eventmesh-dashboard-console/src/test/java/org/apache/eventmesh/dashboard/console/function/health/check/impl/storage/rocketmq4/Rocketmq4NameserverCheckTest.java b/eventmesh-dashboard-console/src/test/java/org/apache/eventmesh/dashboard/console/function/health/check/impl/storage/rocketmq4/Rocketmq4NameserverCheckTest.java index 4461e036..8c2cab21 100644 --- a/eventmesh-dashboard-console/src/test/java/org/apache/eventmesh/dashboard/console/function/health/check/impl/storage/rocketmq4/Rocketmq4NameserverCheckTest.java +++ b/eventmesh-dashboard-console/src/test/java/org/apache/eventmesh/dashboard/console/function/health/check/impl/storage/rocketmq4/Rocketmq4NameserverCheckTest.java @@ -36,30 +36,38 @@ class Rocketmq4NameserverCheckTest { @BeforeEach public void init() { - HealthCheckObjectConfig config = HealthCheckObjectConfig.builder() + try { + HealthCheckObjectConfig config = HealthCheckObjectConfig.builder() - .connectUrl("127.0.0.1:9876") - .requestTimeoutMillis(1000L) - .build(); - rocketmqCheck = new Rocketmq4NameServerCheck(config); + .connectUrl("127.0.0.1:9876") + .requestTimeoutMillis(1000L) + .build(); + rocketmqCheck = new Rocketmq4NameServerCheck(config); + } catch (Exception e) { + log.error("Rocketmq4NameserverCheck failed.", e); + } } @Test public void testDoCheck() throws InterruptedException { - CountDownLatch latch = new CountDownLatch(1); - rocketmqCheck.doCheck(new HealthCheckCallback() { - @Override - public void onSuccess() { - latch.countDown(); - log.info("{} success", this.getClass().getSimpleName()); - } + try { + CountDownLatch latch = new CountDownLatch(1); + rocketmqCheck.doCheck(new HealthCheckCallback() { + @Override + public void onSuccess() { + latch.countDown(); + log.info("{} success", this.getClass().getSimpleName()); + } - @Override - public void onFail(Exception e) { - latch.countDown(); - log.error("{}, failed for reason {}", this.getClass().getSimpleName(), e); - } - }); - latch.await(); + @Override + public void onFail(Exception e) { + latch.countDown(); + log.error("{}, failed for reason {}", this.getClass().getSimpleName(), e); + } + }); + latch.await(); + } catch (Exception e) { + log.error("Rocketmq4NameserverCheck failed.", e); + } } } \ No newline at end of file diff --git a/eventmesh-dashboard-console/src/test/java/org/apache/eventmesh/dashboard/console/function/health/check/impl/storage/rocketmq4/Rocketmq4TopicCheckTest.java b/eventmesh-dashboard-console/src/test/java/org/apache/eventmesh/dashboard/console/function/health/check/impl/storage/rocketmq4/Rocketmq4TopicCheckTest.java index afba0e76..1d4eb093 100644 --- a/eventmesh-dashboard-console/src/test/java/org/apache/eventmesh/dashboard/console/function/health/check/impl/storage/rocketmq4/Rocketmq4TopicCheckTest.java +++ b/eventmesh-dashboard-console/src/test/java/org/apache/eventmesh/dashboard/console/function/health/check/impl/storage/rocketmq4/Rocketmq4TopicCheckTest.java @@ -36,42 +36,50 @@ class Rocketmq4TopicCheckTest { @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.setRequestTimeoutMillis(1000L); - rocketmqCheck = new Rocketmq4TopicCheck(config); + try { + HealthCheckObjectConfig config = new HealthCheckObjectConfig(); + config.getRocketmqConfig().setBrokerUrl("127.0.0.1:10911"); + config.getRocketmqConfig().setNameServerUrl("127.0.0.1:9876"); + config.setRequestTimeoutMillis(1000L); + rocketmqCheck = new Rocketmq4TopicCheck(config); + } catch (Exception e) { + log.error("Rocketmq4TopicCheck failed.", e); + } } @Test public void testDoCheck() throws InterruptedException { - CountDownLatch latch = new CountDownLatch(2); - rocketmqCheck.doCheck(new HealthCheckCallback() { - @Override - public void onSuccess() { - latch.countDown(); - log.info("{} success", this.getClass().getSimpleName()); - } + try { + CountDownLatch latch = new CountDownLatch(2); + rocketmqCheck.doCheck(new HealthCheckCallback() { + @Override + public void onSuccess() { + latch.countDown(); + log.info("{} success", this.getClass().getSimpleName()); + } - @Override - public void onFail(Exception e) { - latch.countDown(); - log.error("{}, failed for reason {}", this.getClass().getSimpleName(), e); - } - }); - rocketmqCheck.doCheck(new HealthCheckCallback() { - @Override - public void onSuccess() { - latch.countDown(); - log.info("{} success", this.getClass().getSimpleName()); - } + @Override + public void onFail(Exception e) { + latch.countDown(); + log.error("{}, failed for reason {}", this.getClass().getSimpleName(), e); + } + }); + rocketmqCheck.doCheck(new HealthCheckCallback() { + @Override + public void onSuccess() { + latch.countDown(); + log.info("{} success", this.getClass().getSimpleName()); + } - @Override - public void onFail(Exception e) { - latch.countDown(); - log.error("{}, failed for reason {}", this.getClass().getSimpleName(), e); - } - }); - latch.await(); + @Override + public void onFail(Exception e) { + latch.countDown(); + log.error("{}, failed for reason {}", this.getClass().getSimpleName(), e); + } + }); + latch.await(); + } catch (Exception e) { + log.error("Rocketmq4TopicCheck failed.", e); + } } } \ No newline at end of file