PaxosPropose.RequestHandler (apache-cassandra API)

java.lang.Object

org.apache.cassandra.service.paxos.PaxosPropose.RequestHandler

All Implemented Interfaces:: IVerbHandler<org.apache.cassandra.service.paxos.PaxosPropose.Request>

Enclosing class:: PaxosPropose<OnDone extends Consumer<? super org.apache.cassandra.service.paxos.PaxosPropose.Status>>

public static class PaxosPropose.RequestHandler extends 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

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 Details
- RequestHandler
  
  public RequestHandler()
Method Details
- 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.
- execute
  
  public static org.apache.cassandra.service.paxos.PaxosPropose.Response execute(Commit.Proposal proposal, InetAddressAndPort from)