1 files changed, 90 insertions, 0 deletions
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
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;
+	}
+
+}