Package org.apache.cassandra.tools

Class RepairRunner

java.lang.Object

org.apache.cassandra.utils.progress.jmx.JMXNotificationProgressListener

org.apache.cassandra.tools.RepairRunner

All Implemented Interfaces:

java.util.EventListener, javax.management.NotificationListener, ProgressListener

public class RepairRunner
extends JMXNotificationProgressListener

Constructor Summary

Constructors

Constructor	Description
RepairRunner(java.io.PrintStream out, StorageServiceMBean ssProxy, java.lang.String keyspace, java.util.Map<java.lang.String,java.lang.String> options)

Method Summary

Modifier and Type	Method	Description
void	handleConnectionClosed(long timestamp, java.lang.String message)	Called when JMX connection is closed.
void	handleConnectionFailed(long timestamp, java.lang.String message)	Called when JMX connection is failed.
void	handleNotificationLost(long timestamp, java.lang.String message)	Called when receiving JMXConnectionNotification.NOTIFS_LOST message.
boolean	isInterestedIn(java.lang.String tag)
void	progress(java.lang.String tag, ProgressEvent event)	Called when some progress is made by progress publisher.
void	run()

Methods inherited from class org.apache.cassandra.utils.progress.jmx.JMXNotificationProgressListener

handleNotification

Methods inherited from class java.lang.Object

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

Constructor Detail

RepairRunner

public RepairRunner(java.io.PrintStream out,
                    StorageServiceMBean ssProxy,
                    java.lang.String keyspace,
                    java.util.Map<java.lang.String,java.lang.String> options)

Method Detail

run

public void run()
         throws java.lang.Exception

Throws:

java.lang.Exception

isInterestedIn

public boolean isInterestedIn(java.lang.String tag)

Specified by:

isInterestedIn in class JMXNotificationProgressListener

Parameters:

tag - tag name to be checked

Returns:

true if given tag for ProgressEvent is a target to consume. If this returns false, then ProgressListener.progress(java.lang.String, org.apache.cassandra.utils.progress.ProgressEvent) is not called for that event.

handleNotificationLost

public void handleNotificationLost(long timestamp,
                                   java.lang.String message)

Description copied from class: JMXNotificationProgressListener

Called when receiving JMXConnectionNotification.NOTIFS_LOST message.

Overrides:

handleNotificationLost in class JMXNotificationProgressListener

handleConnectionClosed

public void handleConnectionClosed(long timestamp,
                                   java.lang.String message)

Description copied from class: JMXNotificationProgressListener

Called when JMX connection is closed. Specifically when JMXConnectionNotification.CLOSED message is received.

Overrides:

handleConnectionClosed in class JMXNotificationProgressListener

handleConnectionFailed

public void handleConnectionFailed(long timestamp,
                                   java.lang.String message)

Description copied from class: JMXNotificationProgressListener

Called when JMX connection is failed. Specifically when JMXConnectionNotification.FAILED message is received.

Overrides:

handleConnectionFailed in class JMXNotificationProgressListener

progress

public void progress(java.lang.String tag,
                     ProgressEvent event)

Description copied from interface: ProgressListener

Called when some progress is made by progress publisher.

Parameters:

tag - String that identifies progress event.

event - Current progress