org.openecomp.sdc.be.model.cache.workers

Class SyncWorker

java.lang.Object

org.openecomp.sdc.be.model.cache.workers.SyncWorker

All Implemented Interfaces:

Runnable, IWorker

public class SyncWorker
extends Object
implements Runnable, IWorker

the class creates a worker that is used to update cache date, in case of failures and inconsistencies

Constructor Summary

Constructors

Constructor and Description
SyncWorker(String workerName, CacheMangerOperation cacheMangerOperation) creates the sync worker

Method Summary

Modifier and Type	Method and Description
void	collectAllCacheRecords() the method collects all the records from cache except the component itself
void	run() the method collects all the resources/services/products from graph and checks if the component representing them in the cache is valid logic: if the record is present in the graph but not in cache -> create a job that will update the record oin cache if the timestamp of the record in cache is older than the timestamp on the graph -> create a job that will update the record oin cache otherwise no update is required
void	shutDown() the method sets the shutdown flag, when set the worker will stop it's execution as soon as possible with out completing its work

Methods inherited from class java.lang.Object

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

Constructor Detail

SyncWorker

public SyncWorker(String workerName,
                  CacheMangerOperation cacheMangerOperation)

creates the sync worker

Parameters:

workerName - the name of the worker

cacheMangerOperation - responsible for all persistence's operations to graph and the cache

Method Detail

run

public void run()

the method collects all the resources/services/products from graph and checks if the component representing them in the cache is valid logic: if the record is present in the graph but not in cache -> create a job that will update the record oin cache if the timestamp of the record in cache is older than the timestamp on the graph -> create a job that will update the record oin cache otherwise no update is required

Specified by:

run in interface Runnable

collectAllCacheRecords

public void collectAllCacheRecords()

the method collects all the records from cache except the component itself

shutDown

public void shutDown()

the method sets the shutdown flag, when set the worker will stop it's execution as soon as possible with out completing its work

Specified by:

shutDown in interface IWorker