add deleteThreshold

monkeymq · Aug 4, 2017 · 96ed4d8 · 96ed4d8
1 parent 8543ea9
commit 96ed4d8
Showing 1 changed file with 11 additions and 0 deletions.
diff --git a/src/main/java/net/lvsq/jgossip/core/GossipSettings.java b/src/main/java/net/lvsq/jgossip/core/GossipSettings.java
@@ -35,6 +35,9 @@ public class GossipSettings {
     //Which message sync implementation. Default is UDPMsgService.class
     private MsgService msgService = new UDPMsgService();
 
+    //Delete the deadth node when the sync message is not received more than [deleteThreshold] times
+    private int deleteThreshold = 3;
+
     private List<SeedMember> seedMembers;
 
     public int getGossipInterval() {
@@ -78,4 +81,12 @@ public MsgService getMsgService() {
     public void setMsgService(MsgService msgService) {
         this.msgService = msgService;
     }
+
+    public int getDeleteThreshold() {
+        return deleteThreshold;
+    }
+
+    public void setDeleteThreshold(int deleteThreshold) {
+        this.deleteThreshold = deleteThreshold;
+    }
 }