From a44edc79f3aed01f9969168df8e129f9a9007fc9 Mon Sep 17 00:00:00 2001 From: Artem Vysochyn Date: Thu, 11 Jul 2024 23:19:53 +0300 Subject: [PATCH] WIP --- .../io/scalecube/cluster2/membership/MembershipProtocol.java | 4 +--- 1 file changed, 1 insertion(+), 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 index d1f5fc8e..f1b33f06 100644 --- 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,7 +35,6 @@ public MembershipProtocol( BroadcastTransmitter messageTx, Supplier messageRxSupplier, EpochClock epochClock, - CallbackInvoker callbackInvoker, MembershipConfig config, Member localMember) { super( @@ -44,7 +42,7 @@ public MembershipProtocol( messageTx, messageRxSupplier, epochClock, - callbackInvoker, + null, Duration.ofMillis(config.syncInterval())); this.config = config; this.localMember = localMember;