diff --git a/klein-consensus/klein-consensus-paxos/src/main/java/com/ofcoder/klein/consensus/paxos/PaxosNode.java b/klein-consensus/klein-consensus-paxos/src/main/java/com/ofcoder/klein/consensus/paxos/PaxosNode.java index 55c9f9e5..8f97f491 100644 --- a/klein-consensus/klein-consensus-paxos/src/main/java/com/ofcoder/klein/consensus/paxos/PaxosNode.java +++ b/klein-consensus/klein-consensus-paxos/src/main/java/com/ofcoder/klein/consensus/paxos/PaxosNode.java @@ -16,14 +16,12 @@ */ package com.ofcoder.klein.consensus.paxos; -import java.util.Objects; -import java.util.concurrent.atomic.AtomicReference; - import com.ofcoder.klein.consensus.facade.Node; -import com.ofcoder.klein.consensus.paxos.core.ProposerImpl; import com.ofcoder.klein.consensus.paxos.core.sm.MemberRegistry; import com.ofcoder.klein.rpc.facade.Endpoint; +import java.util.Objects; + /** * paxos node info. * diff --git a/klein-consensus/klein-consensus-paxos/src/main/java/com/ofcoder/klein/consensus/paxos/core/RuntimeAccessor.java b/klein-consensus/klein-consensus-paxos/src/main/java/com/ofcoder/klein/consensus/paxos/core/RuntimeAccessor.java index 6ce4f98e..2568b2bc 100644 --- a/klein-consensus/klein-consensus-paxos/src/main/java/com/ofcoder/klein/consensus/paxos/core/RuntimeAccessor.java +++ b/klein-consensus/klein-consensus-paxos/src/main/java/com/ofcoder/klein/consensus/paxos/core/RuntimeAccessor.java @@ -36,9 +36,11 @@ public class RuntimeAccessor { public static AtomicReference getSkipPrepare() { return skipPrepare; } + public static Proposer getProposer() { return proposer; } + public static Acceptor getAcceptor() { return acceptor; }