1 files changed, 87 insertions, 0 deletions
diff --git a/apiroute/apiroute-service/src/main/java/org/onap/msb/apiroute/wrapper/consulextend/expose/WatchTask.java b/apiroute/apiroute-service/src/main/java/org/onap/msb/apiroute/wrapper/consulextend/expose/WatchTask.java
new file mode 100644
index 0000000..2ada19d
--- /dev/null
+++ b/apiroute/apiroute-service/src/main/java/org/onap/msb/apiroute/wrapper/consulextend/expose/WatchTask.java
@@ -0,0 +1,87 @@
+package org.onap.msb.apiroute.wrapper.consulextend.expose;
+
+import java.util.concurrent.CopyOnWriteArrayList;
+
+import org.onap.msb.apiroute.wrapper.consulextend.cache.ConsulCache;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import com.orbitz.consul.model.ConsulResponse;
+
+public abstract class WatchTask<T> {
+	private final CopyOnWriteArrayList<Filter<T>> filters = new CopyOnWriteArrayList<Filter<T>>();
+	private final CopyOnWriteArrayList<Handler<T>> handlers = new CopyOnWriteArrayList<Handler<T>>();
+	private final static Logger LOGGER = LoggerFactory
+			.getLogger(WatchTask.class);
+	
+	//start
+	public abstract boolean startWatch();
+	
+	//stop
+	public abstract boolean stopWatch();
+	
+	// filters
+	public interface Filter<T> {
+		public boolean filter(final ConsulResponse<T> object);
+	}
+
+	public boolean addFilter(Filter<T> filter) {
+		boolean added = filters.add(filter);
+		return added;
+	}
+	
+	public void removeAllFilter() {
+		filters.clear();
+	}
+
+
+	public final CopyOnWriteArrayList<Filter<T>> getAllFilters(){
+		return filters;
+	}
+	
+	// handlers
+	public interface Handler<T> {
+		void handle(final ConsulResponse<T> object);
+	}
+
+	public boolean addHandler(Handler<T> handler) {
+		boolean added = handlers.add(handler);
+		return added;
+	}
+	
+	public void removeAllHandler() {
+		handlers.clear();
+	}
+	
+	// internal listener
+	protected class InternalListener implements ConsulCache.Listener<T> {
+		@Override
+		public void notify(ConsulResponse<T> newValues) {
+			
+			long startTime = System.currentTimeMillis();
+			
+			// filter
+			for (Filter<T> f : filters) {
+				// false,return
+				if (!f.filter(newValues)) {
+					return;
+				}
+			}
+
+			// handle
+			for (Handler<T> h : handlers) {
+				h.handle(newValues);
+			}
+			
+			long endTime = System.currentTimeMillis();
+			
+			if(endTime-startTime > 10*1000)
+			{
+				LOGGER.info("WatchTask THEAD WORK TIMEOUT");
+			}
+		}
+
+	}
+
+
+}