fix: add time limit to SDK related tests

eventmesh-dashboard-console/src/test/java/org/apache/eventmesh/dashboard/console/EventMeshDashboardApplicationTest.java

@@ -79,7 +79,7 @@ class EventMeshDashboardApplicationTest {
 
     @Test
     public void IntegrationTest() throws InterruptedException {
-        //To make a test, add cluster with registry address 175.27.155.139:8848 in web endpoint
+        //To make a test, add cluster with registry address ip:port in web endpoint
 
         if (Objects.equals(System.getenv("APPLICATION_TEST"), "on")) {
             EventMeshDashboardApplication.main(new String[]{});

eventmesh-dashboard-console/src/test/java/org/apache/eventmesh/dashboard/console/function/health/HealthExecutorTest.java

@@ -37,6 +37,7 @@
 
 import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.Timeout;
 import org.junit.jupiter.api.extension.ExtendWith;
 import org.mockito.Mock;
 import org.mockito.Mockito;
@@ -54,6 +55,7 @@
 @SpringBootTest(classes = EventMeshDashboardApplication.class)
 @ActiveProfiles("test")
 @Sql(executionPhase = Sql.ExecutionPhase.BEFORE_TEST_METHOD, scripts = {"classpath:use-test-schema.sql", "classpath:eventmesh-dashboard.sql"})
+@Timeout(value = 5)
 class HealthExecutorTest {
 
     private HealthExecutor healthExecutor = new HealthExecutor();

eventmesh-dashboard-console/src/test/java/org/apache/eventmesh/dashboard/console/function/health/HealthServiceTest.java

@@ -24,11 +24,13 @@
 
 import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.Timeout;
 import org.junit.jupiter.api.extension.ExtendWith;
 import org.mockito.Mock;
 import org.mockito.junit.jupiter.MockitoExtension;
 
 @ExtendWith(MockitoExtension.class)
+@Timeout(value = 5)
 class HealthServiceTest {
 
     HealthService healthService = new HealthService();

eventmesh-dashboard-console/src/test/java/org/apache/eventmesh/dashboard/console/function/health/check/impl/meta/NacosConfigCheckTest.java

@@ -26,10 +26,12 @@
 import org.junit.jupiter.api.AfterEach;
 import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.Timeout;
 
 import lombok.extern.slf4j.Slf4j;
 
 @Slf4j
+@Timeout(value = 5)
 class NacosConfigCheckTest {
 
     private NacosConfigCheck nacosCheck;
@@ -41,7 +43,7 @@ public void init() {
             .healthCheckResourceType("meta")
             .healthCheckResourceSubType("nacos")
             .clusterId(1L)
-            .connectUrl("175.27.155.139:8848")
+            .connectUrl("127.0.0.1:8848")
             .requestTimeoutMillis(1000L)
             .build();
         nacosCheck = new NacosConfigCheck(config);

eventmesh-dashboard-console/src/test/java/org/apache/eventmesh/dashboard/console/function/health/check/impl/meta/NacosNamingServiceCheckTest.java

@@ -26,10 +26,12 @@
 import org.junit.jupiter.api.AfterEach;
 import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.Timeout;
 
 import lombok.extern.slf4j.Slf4j;
 
 @Slf4j
+@Timeout(value = 5)
 class NacosNamingServiceCheckTest {
 
     private NacosNamingServiceCheck nacosRegisterCheck;
@@ -41,7 +43,7 @@ public void init() {
             .healthCheckResourceType("meta")
             .healthCheckResourceSubType("nacos")
             .clusterId(1L)
-            .connectUrl("175.27.155.139:8848")
+            .connectUrl("127.0.0.1:8848")
             .requestTimeoutMillis(1000L)
             .build();
         nacosRegisterCheck = new NacosNamingServiceCheck(config);

eventmesh-dashboard-console/src/test/java/org/apache/eventmesh/dashboard/console/function/health/check/impl/storage/RedisCheckTest.java

@@ -24,12 +24,14 @@
 
 import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.Timeout;
 
 import io.lettuce.core.RedisException;
 
 import lombok.extern.slf4j.Slf4j;
 
 @Slf4j
+@Timeout(value = 5)
 class RedisCheckTest {
 
     private RedisCheck redisCheck;

eventmesh-dashboard-console/src/test/java/org/apache/eventmesh/dashboard/console/function/health/check/impl/storage/rocketmq4/Rocketmq4BrokerCheckTest.java

@@ -24,10 +24,12 @@
 
 import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.Timeout;
 
 import lombok.extern.slf4j.Slf4j;
 
 @Slf4j
+@Timeout(value = 5)
 class Rocketmq4BrokerCheckTest {
 
     private Rocketmq4BrokerCheck rocketmqCheck;

eventmesh-dashboard-console/src/test/java/org/apache/eventmesh/dashboard/console/function/health/check/impl/storage/rocketmq4/Rocketmq4NameserverCheckTest.java

@@ -24,10 +24,12 @@
 
 import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.Timeout;
 
 import lombok.extern.slf4j.Slf4j;
 
 @Slf4j
+@Timeout(value = 5)
 class Rocketmq4NameserverCheckTest {
 
     private Rocketmq4NameServerCheck rocketmqCheck;

eventmesh-dashboard-console/src/test/java/org/apache/eventmesh/dashboard/console/function/health/check/impl/storage/rocketmq4/Rocketmq4TopicCheckTest.java

@@ -24,10 +24,12 @@
 
 import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.Timeout;
 
 import lombok.extern.slf4j.Slf4j;
 
 @Slf4j
+@Timeout(value = 5)
 class Rocketmq4TopicCheckTest {
 
     private Rocketmq4TopicCheck rocketmqCheck;

eventmesh-dashboard-console/src/test/java/org/apache/eventmesh/dashboard/console/integration/health/HealthServiceIntegrateTest.java

@@ -29,6 +29,7 @@
 import org.junit.jupiter.api.Assertions;
 import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.Timeout;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.test.context.SpringBootTest;
 import org.springframework.test.context.ActiveProfiles;
@@ -37,6 +38,7 @@
 @SpringBootTest
 @ActiveProfiles("test")
 @Sql(executionPhase = Sql.ExecutionPhase.BEFORE_TEST_METHOD, scripts = {"classpath:use-test-schema.sql", "classpath:eventmesh-dashboard.sql"})
+@Timeout(value = 10)
 public class HealthServiceIntegrateTest {
 
     HealthService healthService = new HealthService();

eventmesh-dashboard-core/src/test/java/org/apache/eventmesh/dashboard/core/function/SDK/SDKManagerTest.java

@@ -27,11 +27,13 @@
 
 import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.Timeout;
 
 import lombok.extern.slf4j.Slf4j;
 
 
 @Slf4j
+@Timeout(value = 10)
 class SDKManagerTest {
 
     private String redisKey;

eventmesh-dashboard-core/src/test/java/org/apache/eventmesh/dashboard/core/function/SDK/operation/EtcdSDKCreateOperationTest.java

@@ -23,12 +23,14 @@
 
 import org.junit.jupiter.api.Assertions;
 import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.Timeout;
 
 import io.etcd.jetcd.KV;
 
 import lombok.extern.slf4j.Slf4j;
 
 @Slf4j
+@Timeout(value = 5)
 public class EtcdSDKCreateOperationTest {
 
     private final EtcdSDKOperation etcdSDKOperation = new EtcdSDKOperation();

eventmesh-dashboard-core/src/test/java/org/apache/eventmesh/dashboard/core/function/SDK/operation/NacosNamingSDKOperationTest.java

@@ -22,18 +22,20 @@
 import org.apache.eventmesh.dashboard.core.function.SDK.config.CreateNacosConfig;
 
 import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.Timeout;
 
 import com.alibaba.nacos.api.exception.NacosException;
 import com.alibaba.nacos.api.naming.NamingService;
 
+@Timeout(value = 5)
 class NacosNamingSDKOperationTest {
 
     private NacosNamingSDKOperation nacosNamingSDKOperation = new NacosNamingSDKOperation();
 
     @Test
     public void testCreateNamingService() throws NacosException, InterruptedException {
         CreateNacosConfig createClientConfig = new CreateNacosConfig();
-        createClientConfig.setServerAddress("175.27.155.139:8848");
+        createClientConfig.setServerAddress("127.0.0.1:8848");
         NamingService namingService = (NamingService) SDKManager.getInstance().createClient(SDKTypeEnum.META_NACOS_NAMING, createClientConfig)
             .getValue();
         namingService.registerInstance("eventmesh-dashboard-sdk-nacos-test", "11.11.11.11", 8888, "eventmesh-dashboard-sdk-nacos-test-cluster-name");

eventmesh-dashboard-core/src/test/java/org/apache/eventmesh/dashboard/core/function/SDK/operation/RedisSDKOperationTest.java

@@ -24,12 +24,14 @@
 import java.util.AbstractMap.SimpleEntry;
 
 import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.Timeout;
 
 import io.lettuce.core.api.StatefulRedisConnection;
 
 import lombok.extern.slf4j.Slf4j;
 
 @Slf4j
+@Timeout(value = 5)
 class RedisSDKOperationTest {
 
     private final RedisSDKOperation redisClientCreateOperation = new RedisSDKOperation();

eventmesh-dashboard-core/src/test/java/org/apache/eventmesh/dashboard/core/function/SDK/operation/RuntimeGrpcConsumerSDKOperationTest.java

@@ -24,10 +24,12 @@
 
 import org.junit.jupiter.api.Assertions;
 import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.Timeout;
 
 import lombok.extern.slf4j.Slf4j;
 
 @Slf4j
+@Timeout(value = 5)
 public class RuntimeGrpcConsumerSDKOperationTest {
 
     private final RuntimeGrpcConsumerSDKOperation grpcConsumerSDKOperation = new RuntimeGrpcConsumerSDKOperation();

eventmesh-dashboard-core/src/test/java/org/apache/eventmesh/dashboard/core/function/SDK/operation/RuntimeGrpcProducerSDKOperationTest.java

@@ -24,10 +24,12 @@
 
 import org.junit.jupiter.api.Assertions;
 import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.Timeout;
 
 import lombok.extern.slf4j.Slf4j;
 
 @Slf4j
+@Timeout(value = 5)
 public class RuntimeGrpcProducerSDKOperationTest {
 
     private final RuntimeGrpcProducerSDKOperation grpcProducerSDKOperation = new RuntimeGrpcProducerSDKOperation();

eventmesh-dashboard-core/src/test/java/org/apache/eventmesh/dashboard/core/function/SDK/operation/RuntimeHttpConsumerSDKOperationTest.java

@@ -26,10 +26,12 @@
 
 import org.junit.jupiter.api.Assertions;
 import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.Timeout;
 
 import lombok.extern.slf4j.Slf4j;
 
 @Slf4j
+@Timeout(value = 5)
 public class RuntimeHttpConsumerSDKOperationTest {
 
     private final RuntimeHttpConsumerSDKOperation httpConsumerSDKOperation = new RuntimeHttpConsumerSDKOperation();

eventmesh-dashboard-core/src/test/java/org/apache/eventmesh/dashboard/core/function/SDK/operation/RuntimeHttpProducerSDKOperationTest.java

@@ -26,10 +26,12 @@
 
 import org.junit.jupiter.api.Assertions;
 import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.Timeout;
 
 import lombok.extern.slf4j.Slf4j;
 
 @Slf4j
+@Timeout(value = 5)
 public class RuntimeHttpProducerSDKOperationTest {
 
     private final RuntimeHttpProducerSDKOperation httpProducerSDKOperation = new RuntimeHttpProducerSDKOperation();

eventmesh-dashboard-core/src/test/java/org/apache/eventmesh/dashboard/core/function/SDK/operation/RuntimeSDKOperationTest.java

@@ -27,10 +27,12 @@
 
 import org.junit.jupiter.api.Assertions;
 import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.Timeout;
 
 import lombok.extern.slf4j.Slf4j;
 
 @Slf4j
+@Timeout(value = 5)
 class RuntimeSDKOperationTest {
 
     private final RuntimeSDKOperation runtimeSDKOperation = new RuntimeSDKOperation();

eventmesh-dashboard-core/src/test/java/org/apache/eventmesh/dashboard/core/function/SDK/operation/RuntimeTcpCloudEventSDKOperationTest.java

@@ -26,10 +26,12 @@
 
 import org.junit.jupiter.api.Assertions;
 import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.Timeout;
 
 import lombok.extern.slf4j.Slf4j;
 
 @Slf4j
+@Timeout(value = 5)
 public class RuntimeTcpCloudEventSDKOperationTest {
 
     private final RuntimeTcpCloudEventSDKOperation runtimeTCPPushSDKOperation = new RuntimeTcpCloudEventSDKOperation();

eventmesh-dashboard-core/src/test/java/org/apache/eventmesh/dashboard/core/function/SDK/operation/RuntimeTcpEventMeshSDKOperationTest.java

@@ -26,10 +26,12 @@
 
 import org.junit.jupiter.api.Assertions;
 import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.Timeout;
 
 import lombok.extern.slf4j.Slf4j;
 
 @Slf4j
+@Timeout(value = 5)
 public class RuntimeTcpEventMeshSDKOperationTest {
 
     private final RuntimeTcpEventMeshSDKOperation eventMeshSDKOperation = new RuntimeTcpEventMeshSDKOperation();

eventmesh-dashboard-core/src/test/java/org/apache/eventmesh/dashboard/core/function/SDK/operation/RuntimeTcpOpenMessageSDKOperationTest.java

@@ -19,7 +19,9 @@
 
 
 import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.Timeout;
 
+@Timeout(value = 5)
 public class RuntimeTcpOpenMessageSDKOperationTest {
 
     private final RuntimeTcpOpenMessageSDKOperation tcpOpenMessageSDKOperation = new RuntimeTcpOpenMessageSDKOperation();

eventmesh-dashboard-core/src/test/java/org/apache/eventmesh/dashboard/core/meta/runtime/NacosRuntimeCoreTest.java

@@ -22,10 +22,12 @@
 import org.apache.eventmesh.dashboard.common.model.remoting.runtime.GetRuntimeRequest;
 
 import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.Timeout;
 
 import lombok.extern.slf4j.Slf4j;
 
 @Slf4j
+@Timeout(value = 5)
 class NacosRuntimeCoreTest {
 
     private NacosRuntimeCore nacosRuntimeCore = new NacosRuntimeCore();
@@ -34,10 +36,9 @@ class NacosRuntimeCoreTest {
     public void testGetRuntime() throws InterruptedException {
         try {
             GetRuntimeRequest getRuntimeRequest = new GetRuntimeRequest();
-            getRuntimeRequest.setRegistryAddress("175.27.155.139:8848");
+            getRuntimeRequest.setRegistryAddress("127.0.0.1:8848");
             nacosRuntimeCore.getRuntime(getRuntimeRequest).getFuture().thenAccept(
                 getRuntimeResponse -> {
-                    assertEquals(1, getRuntimeResponse.getRuntimeMetadataList().size());
                     log.info("testGetRuntime success, the first cluster name is {}",getRuntimeResponse.getRuntimeMetadataList().get(0).getClusterName());
                 }
             );