Package org.apache.cassandra.service.paxos

Class PaxosPropose.RequestHandler

  • All Implemented Interfaces:
    IVerbHandler<org.apache.cassandra.service.paxos.PaxosPropose.Request>
    Enclosing class:
    PaxosPropose<OnDone extends java.util.function.Consumer<? super org.apache.cassandra.service.paxos.PaxosPropose.Status>>
    public static class PaxosPropose.RequestHandler
extends java.lang.Object
implements IVerbHandler<org.apache.cassandra.service.paxos.PaxosPropose.Request>
    The proposal request handler, i.e. receives a proposal from a peer and responds with either acccept/reject

    • Constructor Summary

      Constructors 
      Constructor Description
      RequestHandler()  

    • Method Summary

      All Methods Static Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void doVerb​(Message<org.apache.cassandra.service.paxos.PaxosPropose.Request> message)
      This method delivers a message to the implementing class (if the implementing class was registered by a call to MessagingService.registerVerbHandlers).
      static org.apache.cassandra.service.paxos.PaxosPropose.Response execute​(Commit.Proposal proposal, InetAddressAndPort from)  

      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    • Constructor Detail

      • RequestHandler

        public RequestHandler()

    • Method Detail

      • doVerb

        public void doVerb​(Message<org.apache.cassandra.service.paxos.PaxosPropose.Request> message)
        Description copied from interface: IVerbHandler
        This method delivers a message to the implementing class (if the implementing class was registered by a call to MessagingService.registerVerbHandlers). Note that the caller should not be holding any locks when calling this method because the implementation may be synchronized.
        Specified by:
        doVerb in interface IVerbHandler<org.apache.cassandra.service.paxos.PaxosPropose.Request>
        Parameters:
        message - - incoming message that needs handling.