org.xmlBlaster.contrib.replication.impl
Class InitialUpdater.ExecutionThread

java.lang.Object
  java.lang.Thread
      org.xmlBlaster.contrib.replication.impl.InitialUpdater.ExecutionThread

All Implemented Interfaces:

java.lang.Runnable

Enclosing class:

InitialUpdater

 class InitialUpdater.ExecutionThread
extends java.lang.Thread

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

java.lang.Thread.State, java.lang.Thread.UncaughtExceptionHandler

Field Summary

private I_DbSpecific	dbSpec
private java.lang.String	initialFilesLocation
private java.lang.String	replManagerAddress
private java.lang.String	replTopic
private java.util.List	slaveNamesList
private java.lang.String	version

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

InitialUpdater.ExecutionThread(java.lang.String replTopic, java.lang.String replManagerAddress, I_DbSpecific dbSpecific, java.lang.String initialFilesLocation)

Method Summary

boolean	add(java.lang.String slaveName, java.lang.String replManagerAddress_, java.lang.String ver) Adds a destination to this initial update (so that it is possible to perform several I.U.
void	process()
void	run()

Methods inherited from class java.lang.Thread

activeCount, checkAccess, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

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

Field Detail

replTopic

private java.lang.String replTopic

dbSpec

private I_DbSpecific dbSpec

initialFilesLocation

private java.lang.String initialFilesLocation

slaveNamesList

private java.util.List slaveNamesList

replManagerAddress

private java.lang.String replManagerAddress

version

private java.lang.String version

Constructor Detail

InitialUpdater.ExecutionThread

public InitialUpdater.ExecutionThread(java.lang.String replTopic,
                                      java.lang.String replManagerAddress,
                                      I_DbSpecific dbSpecific,
                                      java.lang.String initialFilesLocation)

Parameters:

replTopic - The topic to use to publish the initial data

replManagerAddress - The address to which to send the end-of-data message

dbSpecific -

initialFilesLocation -

Method Detail

add

public boolean add(java.lang.String slaveName,
                   java.lang.String replManagerAddress_,
                   java.lang.String ver)

Adds a destination to this initial update (so that it is possible to perform several I.U. with the same data.

Parameters:

destination - The destination (PtP) of this initial Update

slaveName - The name of the slave

version - The version for this update.

Returns:

true if the entry has the correct version, false otherwise (in which case it will not be added).

process

public void process()

run

public void run()

Specified by:

run in interface java.lang.Runnable

Overrides:

run in class java.lang.Thread