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
All Methods Instance Methods Concrete Methods 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()
-
-
-
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 interfaceProgressEventNotifier
- 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 interfaceProgressEventNotifier
- 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 interfacejava.lang.Runnable
-
-