IndexDAO setup is called on PostConstruct

s50600822 · Dec 5, 2020 · d52b528 · d52b528
1 parent 1021e2e
commit d52b528
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 0 deletions.
diff --git a/es6-persistence/src/main/java/com/netflix/conductor/es6/dao/index/ElasticSearchDAOV6.java b/es6-persistence/src/main/java/com/netflix/conductor/es6/dao/index/ElasticSearchDAOV6.java
@@ -63,6 +63,7 @@
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
+import javax.annotation.PostConstruct;
 import javax.annotation.PreDestroy;
 import java.io.IOException;
 import java.text.SimpleDateFormat;
@@ -206,6 +207,7 @@ private void shutdownExecutorService(ExecutorService execService) {
     }
 
     @Override
+    @PostConstruct
     public void setup() throws Exception {
         waitForHealthyCluster();
 

diff --git a/...persistence/src/main/java/com/netflix/conductor/es6/dao/index/ElasticSearchRestDAOV6.java b/...persistence/src/main/java/com/netflix/conductor/es6/dao/index/ElasticSearchRestDAOV6.java
@@ -70,6 +70,7 @@
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
+import javax.annotation.PostConstruct;
 import javax.annotation.PreDestroy;
 import java.io.IOException;
 import java.io.InputStream;
@@ -228,6 +229,7 @@ private void shutdownExecutorService(ExecutorService execService) {
     }
 
     @Override
+    @PostConstruct
     public void setup() throws Exception {
         waitForHealthyCluster();