Package org.apache.cassandra.repair

Class RepairRunnable

java.lang.Object

org.apache.cassandra.repair.RepairRunnable

All Implemented Interfaces:

java.lang.Runnable, ProgressEventNotifier

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

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	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

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)

notifyError

public void notifyError(java.lang.Throwable error)

run

public void run()

Specified by:

run in interface java.lang.Runnable