Package org.apache.cassandra.service.paxos

Class PaxosRequestCallback<T>

java.lang.Object

org.apache.cassandra.service.FailureRecordingCallback<T>

org.apache.cassandra.service.paxos.PaxosRequestCallback<T>

All Implemented Interfaces:

RequestCallback<T>, RequestCallbackWithFailure<T>

Direct Known Subclasses:

PaxosCommit, PaxosPrepare, PaxosPropose

public abstract class PaxosRequestCallback<T>
extends FailureRecordingCallback<T>

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.cassandra.service.FailureRecordingCallback

FailureRecordingCallback.AsMap, FailureRecordingCallback.FailureResponses

Constructor Summary

Constructors

Constructor	Description
PaxosRequestCallback()

Method Summary

Modifier and Type	Method	Description
protected <I> void	executeOnSelf(I parameter, BiFunction<I,InetAddressAndPort,T> execute)
void	onResponse(Message<T> message)
protected abstract void	onResponse(T response, InetAddressAndPort from)

Methods inherited from class org.apache.cassandra.service.FailureRecordingCallback

failureReasonsAsMap, onFailure, onFailureWithMutex

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.cassandra.net.RequestCallback

trackLatencyForSnitch

Methods inherited from interface org.apache.cassandra.net.RequestCallbackWithFailure

invokeOnFailure

Constructor Details

PaxosRequestCallback

public PaxosRequestCallback()

Method Details

onResponse

protected abstract void onResponse(T response,
 InetAddressAndPort from)

onResponse

public void onResponse(Message<T> message)

Parameters:

message - response received.

executeOnSelf

protected <I> void executeOnSelf(I parameter,
 BiFunction<I,InetAddressAndPort,T> execute)