WIP

scalecube · Jul 11, 2024 · a44edc7 · a44edc7
1 parent af21aea
commit a44edc7
Showing 1 changed file with 1 addition and 3 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
@@ -2,7 +2,6 @@
 
 import io.scalecube.cluster.transport.api2.Transport;
 import io.scalecube.cluster2.AbstractAgent;
-import io.scalecube.cluster2.CallbackInvoker;
 import io.scalecube.cluster2.Member;
 import io.scalecube.cluster2.MemberCodec;
 import io.scalecube.cluster2.sbe.FailureDetectorEventDecoder;
@@ -36,15 +35,14 @@ public MembershipProtocol(
       BroadcastTransmitter messageTx,
       Supplier<CopyBroadcastReceiver> messageRxSupplier,
       EpochClock epochClock,
-      CallbackInvoker callbackInvoker,
       MembershipConfig config,
       Member localMember) {
     super(
         transport,
         messageTx,
         messageRxSupplier,
         epochClock,
-        callbackInvoker,
+        null,
         Duration.ofMillis(config.syncInterval()));
     this.config = config;
     this.localMember = localMember;