Package org.apache.cassandra.repair

Class RepairRunnable

java.lang.Object

org.apache.cassandra.repair.RepairRunnable

All Implemented Interfaces:

java.lang.Runnable, RepairNotifier, ProgressEventNotifier

public class RepairRunnable
extends java.lang.Object
implements java.lang.Runnable, ProgressEventNotifier, RepairNotifier

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	RepairRunnable.NeighborsAndRanges

Field Summary

Fields

Modifier and Type	Field	Description
CoordinatorState	state

Constructor Summary

Constructors

Constructor	Description
RepairRunnable(StorageService storageService, int cmd, RepairOption options, java.lang.String keyspace)

Method Summary

Modifier and Type	Method	Description
void	addProgressListener(ProgressListener listener)	Register progress listener to this publisher.
protected void	fireProgressEvent(ProgressEvent event)
void	notification(java.lang.String msg)
void	notifyError(java.lang.Throwable error)
void	notifyProgress(java.lang.String message)
void	removeProgressListener(ProgressListener listener)	Remove progress listener from this publisher.
void	run()

Methods inherited from class java.lang.Object

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

Field Detail

state

public final CoordinatorState state

Constructor Detail

RepairRunnable

public RepairRunnable(StorageService storageService,
                      int cmd,
                      RepairOption options,
                      java.lang.String keyspace)

Method Detail

addProgressListener

public void addProgressListener(ProgressListener listener)

Description copied from interface: ProgressEventNotifier

Register progress listener to this publisher.

Specified by:

addProgressListener in interface ProgressEventNotifier

Parameters:

listener - listener to register.

removeProgressListener

public void removeProgressListener(ProgressListener listener)

Description copied from interface: ProgressEventNotifier

Remove progress listener from this publisher.

Specified by:

removeProgressListener in interface ProgressEventNotifier

Parameters:

listener - listener to remove

fireProgressEvent

protected void fireProgressEvent(ProgressEvent event)

notification

public void notification(java.lang.String msg)

Specified by:

notification in interface RepairNotifier

notifyError

public void notifyError(java.lang.Throwable error)

Specified by:

notifyError in interface RepairNotifier

notifyProgress

public void notifyProgress(java.lang.String message)

Specified by:

notifyProgress in interface RepairNotifier

run

public void run()

Specified by:

run in interface java.lang.Runnable