WIP

scalecube · Jun 20, 2024 · 959a24e · 959a24e
1 parent 475f405
commit 959a24e
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/cluster2/src/main/java/io/scalecube/cluster2/fdetector/FailureDetector.java b/cluster2/src/main/java/io/scalecube/cluster2/fdetector/FailureDetector.java
@@ -34,6 +34,7 @@ public class FailureDetector extends AbstractAgent {
   private final MemberCodec memberCodec = new MemberCodec();
   private final List<Member> pingMembers = new ArrayList<>();
   private final List<Member> pingReqMembers = new ArrayList<>();
+  private final String roleName;
 
   public FailureDetector(
       Transport transport,
@@ -50,11 +51,12 @@ public FailureDetector(
         Duration.ofMillis(config.pingInterval()));
     this.localMember = localMember;
     this.config = config;
+    roleName = "fdetector@" + localMember.address();
   }
 
   @Override
   public String roleName() {
-    return null; // TODO
+    return roleName;
   }
 
   @Override