From 6a82990e1a9dc6ee9beea16f264e6f5b318cbfc4 Mon Sep 17 00:00:00 2001 From: Artem Vysochyn Date: Thu, 11 Jul 2024 23:26:09 +0300 Subject: [PATCH] WIP --- .../scalecube/cluster2/membership/MembershipProtocol.java | 8 ++++++++ 1 file changed, 8 insertions(+) diff --git a/cluster2/src/main/java/io/scalecube/cluster2/membership/MembershipProtocol.java b/cluster2/src/main/java/io/scalecube/cluster2/membership/MembershipProtocol.java index f1b33f06..6fd2498b 100644 --- a/cluster2/src/main/java/io/scalecube/cluster2/membership/MembershipProtocol.java +++ b/cluster2/src/main/java/io/scalecube/cluster2/membership/MembershipProtocol.java @@ -5,6 +5,7 @@ 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; @@ -26,6 +27,7 @@ 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 seedMembers; @@ -76,6 +78,10 @@ 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 } @@ -86,4 +92,6 @@ private void onSync(SyncDecoder decoder) {} private void onSyncAck(SyncAckDecoder decoder) {} private void onFailureDetectorEvent(FailureDetectorEventDecoder decoder) {} + + private void onMembershipRecord(MembershipRecordDecoder decoder) {} }