You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@eventmesh.apache.org by mi...@apache.org on 2021/05/11 03:22:59 UTC

[incubator-eventmesh] branch develop updated: [Issue #337] Fix Http Test Subscriber startup issue by moving the Thread.sleep into the child thread (#338)

This is an automated email from the ASF dual-hosted git repository.

mikexue pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/incubator-eventmesh.git


The following commit(s) were added to refs/heads/develop by this push:
     new 645ae93  [Issue #337] Fix Http Test Subscriber startup issue by moving the Thread.sleep into the child thread (#338)
645ae93 is described below

commit 645ae93d13b613e421b7f9bac336b4828fbe5d7e
Author: jinrongluo <ka...@gmail.com>
AuthorDate: Mon May 10 23:22:50 2021 -0400

    [Issue #337] Fix Http Test Subscriber startup issue by moving the Thread.sleep into the child thread (#338)
    
    * [Issue #337] Fix HttpSubscriber startup issue
    
    * [Issue #337] test commit
    
    * [Issue #337] revert test commit
    
    Co-authored-by: j00441484 <ji...@huawei.com>
---
 .../org/apache/eventmesh/http/demo/sub/service/SubService.java   | 9 ++++++---
 1 file changed, 6 insertions(+), 3 deletions(-)

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 e20fea9..84432ca 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 class SubService implements InitializingBean {
         }));
 
         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();
     }
 }

---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@eventmesh.apache.org
For additional commands, e-mail: commits-help@eventmesh.apache.org