java.lang.Object
   AbsReplication
         com.daffodilwoods.replicator.server.Replicator

---

public class Replicator
extends AbsReplication

Description: Replicator class start the Replicator and give call to job/subscription for execution. It has replicator data source and job list.It also start the FTP server for downloading the scheme and data changes.

Copyright: Copyright 2006

Company: Daffodil Sotware Ltd.

Log

protected static final Logger log

Replicator

public Replicator()

addJob

public void addJob ( _Job job)
throws RepException

Add the job in job list.Exception has been thrown if job already exist with same name.

Parameters:
job -

Throws:
RepException

---

addSubscription

public void addSubscription(Subscription subscription)
throws RepException

Add the subscription in subscription list.Exception has been thrown if subscription already exist with same name.

Parameters:
subscription -

Throws:
RepException

---

deleteJob

public boolean deleteJob(java.lang.String jobName)
throws RepException

Find the job in list and remove it from list

Parameters:
jobName - _JobName

Returns:
Throws:
RepException

---

deleteSubscription

public boolean deleteSubscription (java.lang.String subscriptionName)
throws RepException

Find the subscription in subscription list and remove it from list.

Parameters:
subscriptionName -

Returns:

Throws:
RepException

---

doJob

public void doJob (java.lang.String jobName)
throws RepException

For manual execution of job Is we required to have name of all the job Name in interface.

Throws:
RepException

---

doSubscription

public void doSubscription (java.lang.String subscriptionName)
throws RepException

For mannual execution of subscription, we have required a subscription name for run the subscription.

Parameters:
subscriptionName -

Throws:
RepException

---

doJobs

public void doJobs ()
throws RepException

Perform all the jobs that we have using thread

Throws:
RepException

---

doSubscriptions

public void doSubscriptions ()
throws RepException

Perform all the subscriptions.

Throws:
RepException

---

start

public boolean start ()
throws RepException

Set start replication server flag true. Make the object of DFTPServer. Set the DFTPServer properties and start it. Make the object of DFTPClient.

Throws:
RepException

---

stop

public boolean stop ()

Stop the FTP and Replicator.

---

getJob

public _Job getJob (java.lang.String jobName)

Give the object of job on the basis of object passed to it.

Parameters:
jobName -

Returns:

---

getSubscription

public Subscription getSubscription (java.lang.String subscriptionName)

Give the object of subscription on the basis of passed parameter.

Parameters:
subscriptionName -

Returns:

---

deleteDataSource

public boolean deleteDataSource (java.lang.String dataSouceName)
throws RepException

Find the job in list and remove from it.

Parameters:
dataSouceName -

Throws:
RepException

---

getJobList

public java.util.ArrayList getJobList ()

Get all replicator job in list.

Returns:
job list

---

getSubscriptionList

public java.util.ArrayList getSubscriptionList ()

Get all replicator subscriptions in list.

Returns:

---

addDataSource

public void addDataSource (_DataSource data)
throws RepException

Add the data source in list. Set the read and write flag true if datasource is an instanceof RemoteDataSource.

Parameters:
data - is instance of _DataSource

Throws:
RepException