diff --git a/eventmesh-test/src/main/java/org/apache/eventmesh/http/demo/sub/service/SubService.java b/eventmesh-test/src/main/java/org/apache/eventmesh/http/demo/sub/service/SubService.java index e20fea98be..84432ca003 100644 --- a/eventmesh-test/src/main/java/org/apache/eventmesh/http/demo/sub/service/SubService.java +++ b/eventmesh-test/src/main/java/org/apache/eventmesh/http/demo/sub/service/SubService.java @@ -75,12 +75,15 @@ public void afterPropertiesSet() throws Exception { })); Thread stopThread = new Thread(() -> { + try { + Thread.sleep(5 * 60 * 1000); + } catch (InterruptedException e) { + e.printStackTrace(); + } logger.info("stopThread start...."); System.exit(0); }); - Thread.sleep(5 * 60 * 1000); - -// stopThread.start(); + stopThread.start(); } }