Package de.hybris.platform.catalog.jalo.synchronization

Class CatalogVersionSyncMaster

java.lang.Object

de.hybris.platform.catalog.jalo.synchronization.AbstractCatalogVersionSyncMaster

de.hybris.platform.catalog.jalo.synchronization.CatalogVersionSyncMaster

public class CatalogVersionSyncMaster
extends AbstractCatalogVersionSyncMaster

Since:

3.1-u6

Constructor Summary

Constructors

Constructor	Description
CatalogVersionSyncMaster(CatalogVersionSyncJob job, CatalogVersionSyncCronJob cronJob)

Method Summary

Modifier and Type	Method	Description
protected void	doReadSchedules(SyncScheduleReader scheduleReader, int lastLine)
void	doSynchronization()
protected int	doSyncTurn()
void	dump(SyncSchedule record)
SyncSchedule	fetchNext(CatalogVersionSyncWorker worker)
protected int	getCurrentDumpCount()
protected int	getCurrentDumpDeadlockCount()
int	getCurrentTurn()
boolean	hasErrors()
void	incrementProcessedItemsCount(int weight)
boolean	isIgnoreErrors()
protected void	notifyError(CatalogVersionSyncWorker worker, SyncSchedule scheduledItem, java.lang.Exception exception)
protected boolean	notifyFinished(CatalogVersionSyncWorker worker, SyncSchedule schedule)
protected void	notifyWorkerDied(CatalogVersionSyncWorker worker)
void	runExclusiveIfNecessary(SyncSchedule schedule, java.lang.Runnable r)
protected void	setFirstTurnTotal(int firstTurnTotal)
protected void	waitForEmptyQueue()
protected void	waitForWorkersToDie()

Methods inherited from class de.hybris.platform.catalog.jalo.synchronization.AbstractCatalogVersionSyncMaster

getAllAttributeConfig, getAttributeConfig, getCatalogManager, getCatalogRequiredAttributes, getCatalogVersionAttribute, getCronJob, getJob

Methods inherited from class java.lang.Object

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

Constructor Detail

CatalogVersionSyncMaster

public CatalogVersionSyncMaster(CatalogVersionSyncJob job,
                                CatalogVersionSyncCronJob cronJob)

Method Detail

isIgnoreErrors

public final boolean isIgnoreErrors()

fetchNext

public final SyncSchedule fetchNext(CatalogVersionSyncWorker worker)
                             throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

getCurrentDumpCount

protected int getCurrentDumpCount()

getCurrentDumpDeadlockCount

protected int getCurrentDumpDeadlockCount()

notifyFinished

protected boolean notifyFinished(CatalogVersionSyncWorker worker,
                                 SyncSchedule schedule)

runExclusiveIfNecessary

public void runExclusiveIfNecessary(SyncSchedule schedule,
                                    java.lang.Runnable r)

dump

public void dump(SyncSchedule record)

waitForWorkersToDie

protected void waitForWorkersToDie()

waitForEmptyQueue

protected void waitForEmptyQueue()

doSynchronization

public void doSynchronization()
                       throws AbortCronJobException

Throws:

AbortCronJobException

doSyncTurn

protected int doSyncTurn()
                  throws AbortCronJobException

Throws:

AbortCronJobException

doReadSchedules

protected void doReadSchedules(SyncScheduleReader scheduleReader,
                               int lastLine)
                        throws AbortCronJobException

Throws:

AbortCronJobException

notifyError

protected void notifyError(CatalogVersionSyncWorker worker,
                           SyncSchedule scheduledItem,
                           java.lang.Exception exception)

Parameters:

scheduledItem - the scheduled item which caused the error

exception - the error

Throws:

java.lang.RuntimeException - for any runtime exception unless ignore mode is chose

JaloSystemException - for all non-runtime exception unless ignore mode is chosen

notifyWorkerDied

protected void notifyWorkerDied(CatalogVersionSyncWorker worker)

hasErrors

public boolean hasErrors()

getCurrentTurn

public int getCurrentTurn()

setFirstTurnTotal

protected void setFirstTurnTotal(int firstTurnTotal)

incrementProcessedItemsCount

public void incrementProcessedItemsCount(int weight)