Package org.apache.cassandra.service

Class FailureRecordingCallback<T>

java.lang.Object

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

All Implemented Interfaces:

RequestCallback<T>, RequestCallbackWithFailure<T>

Direct Known Subclasses:

PaxosRequestCallback

public abstract class FailureRecordingCallback<T>
extends Object
implements RequestCallbackWithFailure<T>

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	FailureRecordingCallback.AsMap
static class	FailureRecordingCallback.FailureResponses

Constructor Summary

Constructors

Constructor	Description
FailureRecordingCallback()

Method Summary

Modifier and Type	Method	Description
protected FailureRecordingCallback.AsMap	failureReasonsAsMap()
void	onFailure(InetAddressAndPort from, RequestFailureReason failureReason)	Called when there is an exception on the remote node or timeout happens
protected void	onFailureWithMutex(InetAddressAndPort from, RequestFailureReason failureReason)

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

onResponse, trackLatencyForSnitch

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

invokeOnFailure

Constructor Details

FailureRecordingCallback

public FailureRecordingCallback()

Method Details

onFailure

public void onFailure(InetAddressAndPort from,
 RequestFailureReason failureReason)

Description copied from interface: RequestCallbackWithFailure

Called when there is an exception on the remote node or timeout happens

Specified by:

onFailure in interface RequestCallback<T>

Specified by:

onFailure in interface RequestCallbackWithFailure<T>

onFailureWithMutex

protected void onFailureWithMutex(InetAddressAndPort from,
 RequestFailureReason failureReason)

failureReasonsAsMap

protected FailureRecordingCallback.AsMap failureReasonsAsMap()