[type:fix] e2e test error

moremind · Oct 23, 2023 · d4caaae · d4caaae
1 parent ea7b6d7
commit d4caaae
Showing 1 changed file with 8 additions and 3 deletions.
diff --git a/...yu-sync-data-http/src/main/java/org/apache/shenyu/sync/data/http/HttpSyncDataService.java b/...yu-sync-data-http/src/main/java/org/apache/shenyu/sync/data/http/HttpSyncDataService.java
@@ -39,6 +39,7 @@
 import org.apache.shenyu.sync.data.http.refresh.DataRefreshFactory;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.InitializingBean;
 import org.springframework.http.HttpEntity;
 import org.springframework.http.HttpHeaders;
 import org.springframework.http.HttpMethod;
@@ -60,7 +61,7 @@
 /**
  * HTTP long polling implementation.
  */
-public class HttpSyncDataService implements SyncDataService {
+public class HttpSyncDataService implements SyncDataService, InitializingBean {
 
     /**
      * logger.
@@ -94,7 +95,6 @@ public HttpSyncDataService(final HttpConfig httpConfig,
         this.factory = new DataRefreshFactory(pluginDataSubscriber, metaDataSubscribers, authDataSubscribers, proxySelectorDataSubscribers, discoveryUpstreamDataSubscribers);
         this.serverList = Lists.newArrayList(Splitter.on(",").split(httpConfig.getUrl()));
         this.restTemplate = restTemplate;
-        this.start();
     }
 
     private void start() {
@@ -215,7 +215,12 @@ public void close() {
             executor = null;
         }
     }
-
+
+    @Override
+    public void afterPropertiesSet() throws Exception {
+        this.start();
+    }
+
     class HttpLongPollingTask implements Runnable {
 
         private final String server;