WIP

scalecube · Jul 11, 2024 · af21aea · af21aea
1 parent cef5e97
commit af21aea
Showing 1 changed file with 0 additions and 8 deletions.
diff --git a/cluster2/src/main/java/io/scalecube/cluster2/membership/MembershipProtocol.java b/cluster2/src/main/java/io/scalecube/cluster2/membership/MembershipProtocol.java
@@ -6,7 +6,6 @@
 import io.scalecube.cluster2.Member;
 import io.scalecube.cluster2.MemberCodec;
 import io.scalecube.cluster2.sbe.FailureDetectorEventDecoder;
-import io.scalecube.cluster2.sbe.MembershipRecordDecoder;
 import io.scalecube.cluster2.sbe.MessageHeaderDecoder;
 import io.scalecube.cluster2.sbe.SyncAckDecoder;
 import io.scalecube.cluster2.sbe.SyncDecoder;
@@ -28,7 +27,6 @@ public class MembershipProtocol extends AbstractAgent {
   private final SyncAckDecoder syncAckDecoder = new SyncAckDecoder();
   private final FailureDetectorEventDecoder failureDetectorEventDecoder =
       new FailureDetectorEventDecoder();
-  private final MembershipRecordDecoder membershipRecordDecoder = new MembershipRecordDecoder();
   private final MemberCodec memberCodec = new MemberCodec();
   private final String roleName;
   private List<String> seedMembers;
@@ -80,10 +78,6 @@ public void onMessage(int msgTypeId, MutableDirectBuffer buffer, int index, int
         onFailureDetectorEvent(
             failureDetectorEventDecoder.wrapAndApplyHeader(buffer, index, headerDecoder));
         break;
-      case MembershipRecordDecoder.TEMPLATE_ID:
-        onMembershipRecord(
-            membershipRecordDecoder.wrapAndApplyHeader(buffer, index, headerDecoder));
-        break;
       default:
         // no-op
     }
@@ -94,6 +88,4 @@ private void onSync(SyncDecoder decoder) {}
   private void onSyncAck(SyncAckDecoder decoder) {}
 
   private void onFailureDetectorEvent(FailureDetectorEventDecoder decoder) {}
-
-  private void onMembershipRecord(MembershipRecordDecoder decoder) {}
 }