#326 Add message filtering

dvoraka · Aug 1, 2019 · 08719fc · 08719fc
1 parent 3cb0d44
commit 08719fc
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/storage/src/main/java/dvoraka/avservice/storage/replication/NewReplicationService.java b/storage/src/main/java/dvoraka/avservice/storage/replication/NewReplicationService.java
@@ -81,6 +81,12 @@ public void setMaxResponseTime(int maxTime) {
 
     @Override
     public void onMessage(ReplicationMessage message) {
+
+        // filter out our messages (here for now)
+        if (message.getFromId().equals(nodeId)) {
+            return;
+        }
+
         log.debug("On message ({}): {}", nodeId, message);
     }