Class CatalogVersionSyncMaster
java.lang.Object
de.hybris.platform.catalog.jalo.synchronization.AbstractCatalogVersionSyncMaster
de.hybris.platform.catalog.jalo.synchronization.CatalogVersionSyncMaster
- Since:
- 3.1-u6
-
Constructor Summary
ConstructorsConstructorDescription -
Method Summary
Modifier and TypeMethodDescriptionprotected voiddoReadSchedules(SyncScheduleReader scheduleReader, int lastLine) voidprotected intvoiddump(SyncSchedule record) final SyncSchedulefetchNext(CatalogVersionSyncWorker worker) protected intprotected intintbooleanvoidincrementProcessedItemsCount(int weight) final booleanprotected voidnotifyError(CatalogVersionSyncWorker worker, SyncSchedule scheduledItem, Exception exception) protected booleannotifyFinished(CatalogVersionSyncWorker worker, SyncSchedule schedule) protected voidvoidrunExclusiveIfNecessary(SyncSchedule schedule, Runnable r) protected voidsetFirstTurnTotal(int firstTurnTotal) protected voidprotected voidMethods inherited from class de.hybris.platform.catalog.jalo.synchronization.AbstractCatalogVersionSyncMaster
getAllAttributeConfig, getAttributeConfig, getCatalogManager, getCatalogRequiredAttributes, getCatalogVersionAttribute, getCronJob, getJob
-
Constructor Details
-
CatalogVersionSyncMaster
-
-
Method Details
-
isIgnoreErrors
public final boolean isIgnoreErrors() -
fetchNext
- Throws:
InterruptedException
-
getCurrentDumpCount
protected int getCurrentDumpCount() -
getCurrentDumpDeadlockCount
protected int getCurrentDumpDeadlockCount() -
notifyFinished
-
runExclusiveIfNecessary
-
dump
-
waitForWorkersToDie
protected void waitForWorkersToDie() -
waitForEmptyQueue
protected void waitForEmptyQueue() -
doSynchronization
- Throws:
AbortCronJobException
-
doSyncTurn
- Throws:
AbortCronJobException
-
doReadSchedules
protected void doReadSchedules(SyncScheduleReader scheduleReader, int lastLine) throws AbortCronJobException - Throws:
AbortCronJobException
-
notifyError
protected void notifyError(CatalogVersionSyncWorker worker, SyncSchedule scheduledItem, Exception exception) - Parameters:
scheduledItem- the scheduled item which caused the errorexception- the error- Throws:
RuntimeException- for any runtime exception unless ignore mode is choseJaloSystemException- for all non-runtime exception unless ignore mode is chosen
-
notifyWorkerDied
-
hasErrors
public boolean hasErrors() -
getCurrentTurn
public int getCurrentTurn() -
setFirstTurnTotal
protected void setFirstTurnTotal(int firstTurnTotal) -
incrementProcessedItemsCount
public void incrementProcessedItemsCount(int weight)
-