1 files changed, 48 insertions, 0 deletions
diff --git a/apiroute/apiroute-service/src/main/java/org/onap/msb/apiroute/wrapper/consulextend/expose/ConsulIndexFilter.java b/apiroute/apiroute-service/src/main/java/org/onap/msb/apiroute/wrapper/consulextend/expose/ConsulIndexFilter.java
new file mode 100644
index 0000000..14ab2c7
--- /dev/null
+++ b/apiroute/apiroute-service/src/main/java/org/onap/msb/apiroute/wrapper/consulextend/expose/ConsulIndexFilter.java
@@ -0,0 +1,48 @@
+package org.onap.msb.apiroute.wrapper.consulextend.expose;
+
+import java.math.BigInteger;
+import java.util.concurrent.atomic.AtomicReference;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import com.orbitz.consul.model.ConsulResponse;
+
+public class ConsulIndexFilter<T> implements WatchTask.Filter<T> {
+
+	private final static Logger LOGGER = LoggerFactory
+			.getLogger(ConsulIndexFilter.class);
+
+	private final AtomicReference<BigInteger> latestIndex = new AtomicReference<BigInteger>(
+			null);
+
+	@Override
+	public boolean filter(final ConsulResponse<T> object) {
+		// TODO Auto-generated method stub
+		return isChanged(object);
+	}
+
+	private boolean isChanged(final ConsulResponse<T> consulResponse) {
+
+		if (consulResponse != null && consulResponse.getIndex() != null
+				&& !consulResponse.getIndex().equals(latestIndex.get())) {
+			
+			if(LOGGER.isDebugEnabled()){
+				//第一次不打印
+				if (latestIndex.get()!=null) {
+					LOGGER.debug("consul index compare:new-"
+							+ consulResponse.getIndex() + "  old-"
+							+ latestIndex.get());
+				}
+				
+			}
+
+			this.latestIndex.set(consulResponse.getIndex());
+			return true;
+		}
+
+		return false;
+	}
+	
+	
+}