DBReplicator

Open Source Database Replication

• Home
• Documentation
• Downloads
• Supported Databases
• Community
• Site Help
• Contact
• Resources

Home

JavaDoc

• Developer Documentation
• Resource

org.dbreplicator.replication.schedule
Class ScheduledSynchronizer

java.lang.Object
  org.dbreplicator.replication.schedule.ScheduledSynchronizer

All Implemented Interfaces:

java.lang.Runnable

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

The actual synchronizer

This class implements Runnable and hence has a Run method overridden which starts a thread and performs the required replication operation

Constructor Summary

ScheduledSynchronizer(_ReplicationServer repServer0, AbstractDataBaseHandler dbh, java.lang.String subName0, java.lang.String scheduleName0, java.lang.String scheduleType0, java.lang.String remoteServerName, java.lang.String remotePortNo, java.lang.String recurrenceType0, java.lang.String repType, long schTime, int counter0, java.util.HashMap threadMap0)
This is main class responible for performing the required replication operation at right scheduled time.

Method Summary

void	run() This method performs the required replication operation between publisher and subscriber when the schedule time is reached It updates schedule time in the Rep_ScheduleTable and then enters into wait till the time for the next operation.

Methods inherited from class java.lang.Object

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

Constructor Detail

ScheduledSynchronizer

public ScheduledSynchronizer(_ReplicationServer repServer0,
                             AbstractDataBaseHandler dbh,
                             java.lang.String subName0,
                             java.lang.String scheduleName0,
                             java.lang.String scheduleType0,
                             java.lang.String remoteServerName,
                             java.lang.String remotePortNo,
                             java.lang.String recurrenceType0,
                             java.lang.String repType,
                             long schTime,
                             int counter0,
                             java.util.HashMap threadMap0)
                      throws RepException

This is main class responible for performing the required replication operation at right scheduled time. and updating the scheduled time for next schedule in Rep_ScheduleTable.

Parameters:

repServer0 - _ReplicationServer

dbh - AbstractDatabaseHandler

subName0 - String

scheduleName0 - String

scheduleType0 - String

remoteServerName - String

remotePortNo - String

recurrenceType0 - String

repType - String

schTime - long

counter0 - int

threadMap0 - HashMap

Throws:

RepException

Method Detail

run

public void run()

This method performs the required replication operation between publisher and subscriber when the schedule time is reached It updates schedule time in the Rep_ScheduleTable and then enters into wait till the time for the next operation.

Specified by:

run in interface java.lang.Runnable