com.continuent.tungsten.replicator.extractor.mysql
Class RelayLogTask

java.lang.Object
  com.continuent.tungsten.replicator.extractor.mysql.RelayLogTask

All Implemented Interfaces:

java.lang.Runnable

public class RelayLogTask
extends java.lang.Object
implements java.lang.Runnable

Implements a task that runs in a separate thread to manage relay logs.

Author:

Robert Hodges

Constructor Summary

RelayLogTask(RelayLogClient relayClient)
Creates a new relay log task.

Method Summary

void	cancel() Signal that the task should end.
RelayLogPosition	getPosition() Returns the current relay log position.
boolean	isFinished() Returns true if the task has completed.
void	run() Extracts from the relay log until cancelled or we fail.

Methods inherited from class java.lang.Object

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

Constructor Detail

RelayLogTask

public RelayLogTask(RelayLogClient relayClient)

Creates a new relay log task.

Method Detail

run

public void run()

Extracts from the relay log until cancelled or we fail.

Specified by:

run in interface java.lang.Runnable

cancel

public void cancel()

Signal that the task should end.

isFinished

public boolean isFinished()

Returns true if the task has completed.

getPosition

public RelayLogPosition getPosition()

Returns the current relay log position.