Divide the MSB source codes into two repos

[msb/apigateway.git] / apiroute / apiroute-service / src / main / java / org / onap / msb / apiroute / wrapper / consulextend / expose / WatchCatalogServicesTask.java

diff --git a/apiroute/apiroute-service/src/main/java/org/onap/msb/apiroute/wrapper/consulextend/expose/WatchCatalogServicesTask.java b/apiroute/apiroute-service/src/main/java/org/onap/msb/apiroute/wrapper/consulextend/expose/WatchCatalogServicesTask.java
new file mode 100644 (file)
index 0000000..c21295f
--- /dev/null
+++ b/apiroute/apiroute-service/src/main/java/org/onap/msb/apiroute/wrapper/consulextend/expose/WatchCatalogServicesTask.java
@@ -0,0 +1,90 @@
+package org.onap.msb.apiroute.wrapper.consulextend.expose;
+
+import org.apache.http.HttpEntity;
+import org.onap.msb.apiroute.wrapper.consulextend.CatalogClient;
+import org.onap.msb.apiroute.wrapper.consulextend.cache.ServicesCatalogCache;
+import org.onap.msb.apiroute.wrapper.consulextend.cache.ConsulCache.Listener;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import com.orbitz.consul.option.CatalogOptions;
+import com.orbitz.consul.option.QueryOptions;
+
+public class WatchCatalogServicesTask  extends WatchTask<HttpEntity> {
+
+       private final static Logger LOGGER = LoggerFactory
+                       .getLogger(WatchCatalogServicesTask.class);
+       
+       private ServicesCatalogCache servicesCache = null;
+       
+       public WatchCatalogServicesTask(
+                       final CatalogClient catalogClient,
+            final CatalogOptions catalogOptions,
+            final QueryOptions queryOptions,
+            final int watchSeconds)
+       {
+               initCache(catalogClient,catalogOptions,queryOptions,watchSeconds);
+       }
+       
+       public WatchCatalogServicesTask(
+                       final CatalogClient catalogClient,
+            final int watchSeconds)
+       {
+               initCache(catalogClient,CatalogOptions.BLANK,QueryOptions.BLANK,watchSeconds);
+       }
+       
+       public WatchCatalogServicesTask(
+                       final CatalogClient catalogClient)
+       {
+               initCache(catalogClient,CatalogOptions.BLANK,QueryOptions.BLANK,10);
+       }
+       
+       private ServicesCatalogCache initCache(final CatalogClient catalogClient,
+            final CatalogOptions catalogOptions,
+            final QueryOptions queryOptions,
+            final int watchSeconds) {
+               LOGGER.info("************create all services watch task*****************");
+               servicesCache = ServicesCatalogCache.newCache(catalogClient,
+                               catalogOptions, queryOptions, watchSeconds);
+
+               servicesCache
+               .addListener((Listener<HttpEntity>) new InternalListener());
+
+               return servicesCache;
+       }
+       
+       @Override
+       public boolean startWatch() {
+               // TODO Auto-generated method stub
+               if(servicesCache!=null)
+               {
+                       try {
+                               servicesCache.start();
+                               LOGGER.info("************start all services watch task*****************");
+                               return true;
+                       } catch (Exception e) {
+                               // TODO Auto-generated catch block
+                               LOGGER.warn("start service list watch failed:", e);
+                       }
+               }
+               
+               return false;
+       }
+
+       @Override
+       public boolean stopWatch() {
+               // TODO Auto-generated method stub
+               if (servicesCache != null) {
+                       try {
+                               servicesCache.stop();
+                               LOGGER.info("************stop all services watch task*****************");
+                               return true;
+                       } catch (Exception e) {
+                               // TODO Auto-generated catch block
+                               LOGGER.warn("stop service list watch failed:", e);
+                       }
+               }
+               return false;
+       }
+
+}