Package org.apache.cassandra.repair.messages

Class RepairMessage

java.lang.Object

org.apache.cassandra.repair.messages.RepairMessage

Direct Known Subclasses:

CleanupMessage, FailSession, FinalizeCommit, FinalizePromise, FinalizePropose, PrepareConsistentRequest, PrepareConsistentResponse, PrepareMessage, SnapshotMessage, StatusRequest, StatusResponse, SyncRequest, SyncResponse, ValidationRequest, ValidationResponse

public abstract class RepairMessage
extends Object

Base class of all repair related request/response messages.

Since:

2.0

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	RepairMessage.RepairFailureCallback

Field Summary

Fields

Modifier and Type	Field	Description
static final Set<Verb>	ALLOWS_RETRY
final RepairJobDesc	desc
static final RequestCallback<Object>	NOOP_CALLBACK

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	RepairMessage(RepairJobDesc desc)

Method Summary

Modifier and Type	Method	Description
static Supplier<Boolean>	always()
static Supplier<Boolean>	notDone(Future<?> f)
TimeUUID	parentRepairSession()
static void	sendAck(SharedContext ctx, Message<? extends RepairMessage> message)
static void	sendFailureResponse(SharedContext ctx, Message<?> respondTo)
static void	sendMessageWithFailureCB(SharedContext ctx, Supplier<Boolean> allowRetry, RepairMessage request, Verb verb, InetAddressAndPort endpoint, RepairMessage.RepairFailureCallback failureCallback)
static void	sendMessageWithRetries(SharedContext ctx, Supplier<Boolean> allowRetry, RepairMessage request, Verb verb, InetAddressAndPort endpoint)
static <T> void	sendMessageWithRetries(SharedContext ctx, Supplier<Boolean> allowRetry, RepairMessage request, Verb verb, InetAddressAndPort endpoint, RequestCallback<T> finalCallback)
static void	sendMessageWithRetries(SharedContext ctx, RepairMessage request, Verb verb, InetAddressAndPort endpoint)
static <T> void	sendMessageWithRetries(SharedContext ctx, RepairMessage request, Verb verb, InetAddressAndPort endpoint, RequestCallback<T> finalCallback)

Methods inherited from class java.lang.Object

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

Field Details

ALLOWS_RETRY

public static final Set<Verb> ALLOWS_RETRY

NOOP_CALLBACK

public static final RequestCallback<Object> NOOP_CALLBACK

desc

@Nullable
public final RepairJobDesc desc

Constructor Details

RepairMessage

protected RepairMessage(@Nullable
 RepairJobDesc desc)

Method Details

parentRepairSession

public TimeUUID parentRepairSession()

notDone

public static Supplier<Boolean> notDone(Future<?> f)

always

public static Supplier<Boolean> always()

sendMessageWithRetries

public static <T> void sendMessageWithRetries(SharedContext ctx,
 Supplier<Boolean> allowRetry,
 RepairMessage request,
 Verb verb,
 InetAddressAndPort endpoint,
 RequestCallback<T> finalCallback)

sendMessageWithRetries

public static <T> void sendMessageWithRetries(SharedContext ctx,
 RepairMessage request,
 Verb verb,
 InetAddressAndPort endpoint,
 RequestCallback<T> finalCallback)

sendMessageWithRetries

public static void sendMessageWithRetries(SharedContext ctx,
 RepairMessage request,
 Verb verb,
 InetAddressAndPort endpoint)

sendMessageWithRetries

public static void sendMessageWithRetries(SharedContext ctx,
 Supplier<Boolean> allowRetry,
 RepairMessage request,
 Verb verb,
 InetAddressAndPort endpoint)

sendMessageWithFailureCB

public static void sendMessageWithFailureCB(SharedContext ctx,
 Supplier<Boolean> allowRetry,
 RepairMessage request,
 Verb verb,
 InetAddressAndPort endpoint,
 RepairMessage.RepairFailureCallback failureCallback)

sendFailureResponse

public static void sendFailureResponse(SharedContext ctx,
 Message<?> respondTo)

sendAck

public static void sendAck(SharedContext ctx,
 Message<? extends RepairMessage> message)