org.apache.cassandra.service
Class RepairCallback<T>

java.lang.Object
  org.apache.cassandra.service.RepairCallback<T>

All Implemented Interfaces:

IAsyncCallback, IMessageCallback

public class RepairCallback<T>
extends java.lang.Object
implements IAsyncCallback

Constructor Summary

RepairCallback(IResponseResolver<T> resolver, java.util.List<java.net.InetAddress> endpoints)

Method Summary

T	get() The main difference between this and ReadCallback is, ReadCallback has a ConsistencyLevel it needs to achieve.
void	response(Message message)

Methods inherited from class java.lang.Object

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

Constructor Detail

RepairCallback

public RepairCallback(IResponseResolver<T> resolver,
                      java.util.List<java.net.InetAddress> endpoints)

Method Detail

get

public T get()
      throws java.util.concurrent.TimeoutException,
             DigestMismatchException,
             java.io.IOException

The main difference between this and ReadCallback is, ReadCallback has a ConsistencyLevel it needs to achieve. Repair on the other hand is happy to repair whoever replies within the timeout.

Throws:

java.util.concurrent.TimeoutException

DigestMismatchException

java.io.IOException

response

public void response(Message message)

Specified by:

response in interface IAsyncCallback

Parameters:

message - response received.