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

Class CatalogVersionSyncCronJob

java.lang.Object

de.hybris.platform.util.BridgeAbstraction

de.hybris.platform.jalo.Item

de.hybris.platform.jalo.ExtensibleItem

de.hybris.platform.jalo.c2l.LocalizableItem

de.hybris.platform.jalo.GenericItem

de.hybris.platform.cronjob.jalo.GeneratedCronJob

de.hybris.platform.cronjob.jalo.CronJob

de.hybris.platform.catalog.jalo.GeneratedSyncItemCronJob

de.hybris.platform.catalog.jalo.SyncItemCronJob

de.hybris.platform.catalog.jalo.synchronization.GeneratedCatalogVersionSyncCronJob

de.hybris.platform.catalog.jalo.synchronization.CatalogVersionSyncCronJob

All Implemented Interfaces:

Serializable, Comparable

public class CatalogVersionSyncCronJob
extends GeneratedCatalogVersionSyncCronJob

Superclass for cronjobs which synchronizes the content of a catalog version to another catalog version. Keeps source and target catalog versions.

Since:

3.1-u6

See Also:

• Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class de.hybris.platform.catalog.jalo.SyncItemCronJob

SyncItemCronJob.Confgurator, SyncItemCronJob.Configurator

Nested classes/interfaces inherited from class de.hybris.platform.cronjob.jalo.CronJob

CronJob.CronJobResult, CronJob.CronJobThreadSettings

Nested classes/interfaces inherited from class de.hybris.platform.jalo.GenericItem

GenericItem.GenericItemImpl

Nested classes/interfaces inherited from class de.hybris.platform.jalo.c2l.LocalizableItem

LocalizableItem.LocalizableItemImpl

Nested classes/interfaces inherited from class de.hybris.platform.jalo.ExtensibleItem

ExtensibleItem.ExtensibleItemImpl

Nested classes/interfaces inherited from class de.hybris.platform.jalo.Item

Item.AttributeFilter, Item.AttributeMode, Item.CachedGetter, Item.CachedSetter, Item.ItemAttributeMap, Item.ItemConstraint, Item.ItemImpl, Item.JaloCachedComputationException

Field Summary

Fields inherited from class de.hybris.platform.catalog.jalo.synchronization.GeneratedCatalogVersionSyncCronJob

DEFAULT_INITIAL_ATTRIBUTES, SCHEDULEMEDIAS, SCHEDULEMEDIASHANDLER, STATUSMESSAGE

Fields inherited from class de.hybris.platform.catalog.jalo.GeneratedSyncItemCronJob

ABORTONCOLLIDINGSYNC, CREATESAVEDVALUES, FINISHEDITEMS, FORCEUPDATE, FULLSYNC, JOBHANDLER, PENDINGITEMS

Fields inherited from class de.hybris.platform.cronjob.jalo.CronJob

CFG_FILTERED_CTX_ATTRIBUTES

Fields inherited from class de.hybris.platform.cronjob.jalo.GeneratedCronJob

ACTIVE, ACTIVECRONJOBHISTORY, ALTERNATIVEDATASOURCEID, CHANGERECORDINGENABLED, CHANGES, CODE, CRONJOBHISTORYENTRIES, CRONJOBHISTORYENTRIESHANDLER, CRONJOBPENDINGSTEPSRELATION_MARKMODIFIED, CRONJOBPENDINGSTEPSRELATION_SRC_ORDERED, CRONJOBPENDINGSTEPSRELATION_TGT_ORDERED, CRONJOBPROCESSEDSTEPSRELATION_MARKMODIFIED, CRONJOBPROCESSEDSTEPSRELATION_SRC_ORDERED, CRONJOBPROCESSEDSTEPSRELATION_TGT_ORDERED, CURRENTRETRY, CURRENTSTEP, EMAILADDRESS, EMAILNOTIFICATIONTEMPLATE, ENDTIME, ERRORMODE, FILESCOUNT, FILESDAYSOLD, FILESOPERATOR, JOB, LOGFILES, LOGLEVELDATABASE, LOGLEVELFILE, LOGS, LOGSCOUNT, LOGSDAYSOLD, LOGSHANDLER, LOGSOPERATOR, LOGTEXT, LOGTODATABASE, LOGTOFILE, NODEGROUP, NODEID, NUMBEROFRETRIES, PENDINGSTEPS, PRIORITY, PROCESSEDSTEPS, QUERYCOUNT, REMOVEONEXIT, REQUESTABORT, REQUESTABORTSTEP, RESULT, RETRY, RUNNINGONCLUSTERNODE, SENDEMAIL, SESSIONCONTEXTVALUES, SESSIONCURRENCY, SESSIONLANGUAGE, SESSIONUSER, SINGLEEXECUTABLE, STARTTIME, STATUS, TRIGGERS, TRIGGERSHANDLER, USEREADONLYDATASOURCE

Fields inherited from class de.hybris.platform.jalo.c2l.LocalizableItem

LANGUAGE_FALLBACK_ENABLED

Fields inherited from class de.hybris.platform.jalo.Item

_CREATION_TIME_INTERNAL, _MODIFIED_TIME_INTERNAL, accessorLog, CREATION_TIME, DISABLE_ATTRIBUTE_CHECK, DISABLE_ITEMCHECK_BEFORE_REMOVABLE, EVEN, FEATURE_ACCESSMAP_QUALIFIER, HJMPTS, INITIAL_CREATION_FLAG, isJaloOnly, MODIFIED_TIME, NEGATIVE, NOT_FOUND, OWNER, PK, POSITIVE, SAVE_FROM_SERVICE_LAYER, staticTransientObjects, TYPE

Fields inherited from class de.hybris.platform.util.BridgeAbstraction

impl, tenant

Constructor Summary

Constructors

Constructor	Description
CatalogVersionSyncCronJob()

Method Summary

Modifier and Type	Method	Description
ItemSyncDescriptor	addPendingItem(PK srcPK, PK tgtPK)	Adds a single schedule.
void	addPendingItems(List<PK[]> tokens)	Adds multiple schedules at once.
SyncScheduleWriter	createDumpScheduleWriter(SyncStatusHolder statusHandler)	Creates a new schedule writer to collect dumped schedules.
protected CatalogVersionSyncScheduleMedia	createNewScheduleMedia()
protected SyncScheduleWriter	createScheduleWriter(File file, boolean append, int count, int deadlockCount)
SyncStatusHolder	createStatusHolder()
SyncScheduleReader	createSyncScheduleReader()	Creates a schedule reader provided that a current schedule media exists.
protected String	getDumpFileName()
protected String	getDumpFilesDir()
protected String	getDumpFileTempName()
protected File	getFile(CatalogVersionSyncScheduleMedia scheduleMedia)
Collection	getFinishedItems()	Deprecated. since ages
List<SyncSchedule>	getOriginalSyncScheduleList()	The methods allows to get a SyncSchedule list from the first scheduled medias file (the original full sync list).
Collection	getPendingItems()	Deprecated. since ages
protected CatalogVersionSyncScheduleMedia	getScheduleMedia(boolean create)
boolean	hasSchedules()	Tells whether or not schedules items exists.
protected CatalogVersionSyncCronJobHistory	instantiateCronJobHistory()
Boolean	isChangeRecordingEnabled(SessionContext ctx)	Returns always false.
boolean	isIgnoreErrors()
boolean	isLastDumpsDifferent()
protected SyncScheduleWriter	recreateDumpWriter(int validDumpCount)
void	setChangeRecordingEnabled(SessionContext ctx, boolean enabled)	Disabled.
void	storeDumpedSchedules(SyncScheduleWriter scheduleWriter)	Stores dumped schedules in a new schedule media given a SyncScheduleWriter created via createDumpScheduleWriter(SyncStatusHolder).

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

addToScheduleMedias, addToScheduleMedias, getDefaultAttributeModes, getScheduleMedias, getScheduleMedias, getStatusMessage, getStatusMessage, removeFromScheduleMedias, removeFromScheduleMedias, setScheduleMedias, setScheduleMedias, setStatusMessage, setStatusMessage

Methods inherited from class de.hybris.platform.catalog.jalo.SyncItemCronJob

addPendingItem, addPendingItems, createSessionForCronJob, finishedItem, getConfigurator, getFinishedItemCopy, getFinishedItemPKMap, getFinishedItems, getNextChangeNumber, getPendingDescriptorFor, getPendingDescriptorFor, getPendingDescriptors, getPendingDescriptorsCount, getPendingDescriptorsFor, getPendingItems, setConfigurator, setPendingItems

Methods inherited from class de.hybris.platform.catalog.jalo.GeneratedSyncItemCronJob

createItem, isAbortOnCollidingSync, isAbortOnCollidingSync, isAbortOnCollidingSyncAsPrimitive, isAbortOnCollidingSyncAsPrimitive, isCreateSavedValues, isCreateSavedValues, isCreateSavedValuesAsPrimitive, isCreateSavedValuesAsPrimitive, isForceUpdate, isForceUpdate, isForceUpdateAsPrimitive, isForceUpdateAsPrimitive, isFullSync, isFullSync, isFullSyncAsPrimitive, isFullSyncAsPrimitive, setAbortOnCollidingSync, setAbortOnCollidingSync, setAbortOnCollidingSync, setAbortOnCollidingSync, setCreateSavedValues, setCreateSavedValues, setCreateSavedValues, setCreateSavedValues, setForceUpdate, setForceUpdate, setForceUpdate, setForceUpdate, setFullSync, setFullSync, setFullSync, setFullSync, setPendingItems

Methods inherited from class de.hybris.platform.cronjob.jalo.CronJob

activateCronJobThreadSettings, addChangeDescriptor, addChangeDescriptor, addChangeDescriptor, addChangeDescriptor, addChangeListener, addLog, addLog, addLog, addLog, addLog, addToCounter, addToPendingSteps, addToPendingSteps, addToProcessedSteps, addToProcessedSteps, adjustAttributes, checkLogLevel, convertEnumToLogLevel, convertLogLevelToEnum, createNewLogFile, createRunOnceTrigger, currentStepDone, filterSessionContextValuesFromCronJob, finalizeCronJobHistory, getAbortedStatus, getAbortResult, getChanges, getChanges, getChanges, getChanges, getChanges, getChanges, getChanges, getChanges, getChanges, getChanges, getChanges, getChanges, getChanges, getChanges, getChanges, getChanges, getChanges, getCounter, getCronJobThreadSettings, getCurrentlyExecutingCronJob, getCurrentlyExecutingCronJobFailSave, getDebugLogLevel, getErrorLogLevel, getErrorResult, getFailureResult, getFatalLogLevel, getFinishedEmailBody, getFinishedResult, getFinishedStatus, getInfoLogLevel, getLogFiles, getLogLevelDatabase, getLogLevelFile, getLogs, getLogText, getMostRecentChange, getPausedResult, getPausedStatus, getRendererNotificationContext, getRunningRestartStatus, getRunningStatus, getSuccessResult, getTimeTable, getTimeTable, getUndoFinishedResult, getUnknownLogLevel, getUnknownResult, getUnknownStatus, getWarnLogLevel, hasCurrentlyExecutingCronJob, isAbortable, isEnabledFor, isFinished, isPaused, isRunning, isRunningRestart, mustRunOnOtherNode, notifyChangeListeners, remove, removeAllChangeListener, removeChangeListener, resetCounter, resetFinishedCronJob, sendEmail, setAborted, setCronJobResult, setCurrentlyExecutingCronJob, setCurrentStep, setEndTime, setIsEnabledForCheckDifference, setJob, setLogFiles, setNodeGroup, setNodeID, setPaused, setRequestAbort, setResult, setRunning, setRunningRestart, setStartTime, setStatus, toString, tryToStop, unsetCronJobThreadSettings, unsetCurrentlyExecutingCronJob

Methods inherited from class de.hybris.platform.cronjob.jalo.GeneratedCronJob

addToCronJobHistoryEntries, addToCronJobHistoryEntries, addToTriggers, addToTriggers, getActiveCronJobHistory, getActiveCronJobHistory, getAlternativeDataSourceID, getAlternativeDataSourceID, getChanges, getCode, getCode, getCronJobHistoryEntries, getCronJobHistoryEntries, getCurrentRetry, getCurrentRetry, getCurrentRetryAsPrimitive, getCurrentRetryAsPrimitive, getCurrentStep, getCurrentStep, getEmailAddress, getEmailAddress, getEmailNotificationTemplate, getEmailNotificationTemplate, getEndTime, getEndTime, getErrorMode, getErrorMode, getFilesCount, getFilesCount, getFilesCountAsPrimitive, getFilesCountAsPrimitive, getFilesDaysOld, getFilesDaysOld, getFilesDaysOldAsPrimitive, getFilesDaysOldAsPrimitive, getFilesOperator, getFilesOperator, getJob, getJob, getLogFiles, getLogLevelDatabase, getLogLevelFile, getLogs, getLogs, getLogsCount, getLogsCount, getLogsCountAsPrimitive, getLogsCountAsPrimitive, getLogsDaysOld, getLogsDaysOld, getLogsDaysOldAsPrimitive, getLogsDaysOldAsPrimitive, getLogsOperator, getLogsOperator, getLogText, getNodeGroup, getNodeGroup, getNodeID, getNodeID, getNodeIDAsPrimitive, getNodeIDAsPrimitive, getNumberOfRetries, getNumberOfRetries, getNumberOfRetriesAsPrimitive, getNumberOfRetriesAsPrimitive, getPendingSteps, getPendingSteps, getPendingStepsCount, getPendingStepsCount, getPriority, getPriority, getPriorityAsPrimitive, getPriorityAsPrimitive, getProcessedSteps, getProcessedSteps, getProcessedStepsCount, getProcessedStepsCount, getQueryCount, getQueryCount, getQueryCountAsPrimitive, getQueryCountAsPrimitive, getResult, getResult, getRunningOnClusterNode, getRunningOnClusterNode, getRunningOnClusterNodeAsPrimitive, getRunningOnClusterNodeAsPrimitive, getSessionCurrency, getSessionCurrency, getSessionLanguage, getSessionLanguage, getSessionUser, getSessionUser, getStartTime, getStartTime, getStatus, getStatus, getTriggers, getTriggers, isActive, isActive, isActiveAsPrimitive, isActiveAsPrimitive, isChangeRecordingEnabled, isChangeRecordingEnabledAsPrimitive, isChangeRecordingEnabledAsPrimitive, isLogToDatabase, isLogToDatabase, isLogToDatabaseAsPrimitive, isLogToDatabaseAsPrimitive, isLogToFile, isLogToFile, isLogToFileAsPrimitive, isLogToFileAsPrimitive, isMarkModifiedDisabled, isRemoveOnExit, isRemoveOnExit, isRemoveOnExitAsPrimitive, isRemoveOnExitAsPrimitive, isRequestAbort, isRequestAbort, isRequestAbortAsPrimitive, isRequestAbortAsPrimitive, isRequestAbortStep, isRequestAbortStep, isRequestAbortStepAsPrimitive, isRequestAbortStepAsPrimitive, isRetry, isRetry, isRetryAsPrimitive, isRetryAsPrimitive, isSendEmail, isSendEmail, isSendEmailAsPrimitive, isSendEmailAsPrimitive, isSingleExecutable, isSingleExecutable, isSingleExecutableAsPrimitive, isSingleExecutableAsPrimitive, isUseReadOnlyDatasource, isUseReadOnlyDatasource, isUseReadOnlyDatasourceAsPrimitive, isUseReadOnlyDatasourceAsPrimitive, removeFromCronJobHistoryEntries, removeFromCronJobHistoryEntries, removeFromPendingSteps, removeFromPendingSteps, removeFromProcessedSteps, removeFromProcessedSteps, removeFromTriggers, removeFromTriggers, setActive, setActive, setActive, setActive, setActiveCronJobHistory, setActiveCronJobHistory, setAlternativeDataSourceID, setAlternativeDataSourceID, setChangeRecordingEnabled, setChangeRecordingEnabled, setChangeRecordingEnabled, setCode, setCode, setCronJobHistoryEntries, setCronJobHistoryEntries, setCurrentRetry, setCurrentRetry, setCurrentRetry, setCurrentRetry, setEmailAddress, setEmailAddress, setEmailNotificationTemplate, setEmailNotificationTemplate, setEndTime, setErrorMode, setErrorMode, setFilesCount, setFilesCount, setFilesCount, setFilesCount, setFilesDaysOld, setFilesDaysOld, setFilesDaysOld, setFilesDaysOld, setFilesOperator, setFilesOperator, setJob, setLogFiles, setLogLevelDatabase, setLogLevelDatabase, setLogLevelFile, setLogLevelFile, setLogsCount, setLogsCount, setLogsCount, setLogsCount, setLogsDaysOld, setLogsDaysOld, setLogsDaysOld, setLogsDaysOld, setLogsOperator, setLogsOperator, setLogToDatabase, setLogToDatabase, setLogToDatabase, setLogToDatabase, setLogToFile, setLogToFile, setLogToFile, setLogToFile, setNodeGroup, setNodeID, setNodeID, setNodeID, setNumberOfRetries, setNumberOfRetries, setNumberOfRetries, setNumberOfRetries, setPendingSteps, setPendingSteps, setPriority, setPriority, setPriority, setPriority, setProcessedSteps, setProcessedSteps, setQueryCount, setQueryCount, setQueryCount, setQueryCount, setRemoveOnExit, setRemoveOnExit, setRemoveOnExit, setRemoveOnExit, setRequestAbort, setRequestAbort, setRequestAbort, setRequestAbortStep, setRequestAbortStep, setRequestAbortStep, setRequestAbortStep, setResult, setRetry, setRetry, setRetry, setRetry, setRunningOnClusterNode, setRunningOnClusterNode, setRunningOnClusterNode, setRunningOnClusterNode, setSendEmail, setSendEmail, setSendEmail, setSendEmail, setSessionCurrency, setSessionCurrency, setSessionLanguage, setSessionLanguage, setSessionUser, setSessionUser, setSingleExecutable, setSingleExecutable, setSingleExecutable, setSingleExecutable, setStartTime, setStatus, setTriggers, setTriggers, setUseReadOnlyDatasource, setUseReadOnlyDatasource, setUseReadOnlyDatasource, setUseReadOnlyDatasource

Methods inherited from class de.hybris.platform.jalo.GenericItem

getImplementation, getInitialProperties, getNonInitialAttributes, getRelatedItems, getRelatedItems, setRelatedItems

Methods inherited from class de.hybris.platform.jalo.c2l.LocalizableItem

getAllLocalizedProperties, getAllLocalizedProperties, getAllLocalizedProperties, getAllLocalizedProperties, getAllValuesSessionContext, getLocalizedProperty, getLocalizedProperty, getLocalizedPropertyInternal, getLocalizedPropertyNames, getLocalizedPropertyNames, hasLanguage, isEmptyValue, isFallbackEnabled, removeLocalizedProperty, removeLocalizedProperty, setAllLocalizedProperties, setAllLocalizedProperties, setLocalizedProperty, setLocalizedProperty

Methods inherited from class de.hybris.platform.jalo.ExtensibleItem

createNonClassAccessor, getAllProperties, getAllProperties, getProperty, getProperty, getPropertyNames, getPropertyNames, removeProperty, removeProperty, setAllProperties, setAllProperties, setProperty, setProperty

Methods inherited from class de.hybris.platform.jalo.Item

addLinkedItems, addLinkedItems, addLinkedItems, addLinkedItems, addLinkedItems, addLinkedItems, addLinkedItems, addLinkedItems, addLinkedItems, addNegativePermission, addPermission, addPositivePermission, assureExtensionsLoaded, changeTypeAfterCreation, checkConstraint, checkItemPermission, checkMandatoryAttribute, checkMandatoryAttribute, checkPermission, checkPermission, checkRemovable, clearPermission, compareTo, ctx, doAfterRemove, doBeforeRemove, equals, getAccessorFor, getAllAttributes, getAllAttributes, getAllAttributes, getAllAttributes, getAllAttributesInternal, getAllLinkedItems, getAndCheckCacheBoundItem, getAttribute, getAttribute, getCacheBoundItem, getComposedType, getComposedTypePK, getCreationTime, getCurrentlyRemovingCount, getLinkedItems, getLinkedItems, getLinkedItems, getLinkedItems, getLinkedItems, getLinkedItems, getLinkedItems, getLinkedItemsCount, getLinkedItemsCount, getLinkedItemsCount, getModificationTime, getNegativePermissions, getOwner, getPartOfRemovedSessionMarker, getPermissionMap, getPermissions, getPersistenceVersion, getPK, getPositivePermissions, getRestrictedPrincipals, getSession, getSyncObject, getTenant, getTransientObject, getTransientObjectMap, hashCode, hasRegisteredClassAccessorFor, internal_registerClassAccessorFor, internal_registerNonClassAccessorFor, invalidateLocalCaches, isAlive, isCacheBound, isCurrentlyRemoving, isCurrentlyRemoving, isEmptyRelationValue, isInCreate, isInstanceOf, isItemCheckBeforeRemoveableDisabled, isRelationLocalizationFallbackEnabled, newInstance, notifyExtensionsAfterItemCreation, notifyExtensionsBeforeItemCreation, notifyItemRemoval, notifyManagerAboutItemRemoval, readResolve, registerAccessFor, registerAccessFor, registerJaloInvalidationListeners, remove, removeItemCollection, removeItemCollection, removeLinkedItems, removeLinkedItems, removeLinkedItems, removeLinkedItems, removeLinks, removePartOfItems, removePartOfItems, setAllAttributes, setAllAttributes, setAllAttributesInternal, setAllLinkedItems, setAllLinkedItems, setAllLinkedItems, setAllLinkedItems, setAttribute, setAttribute, setAttributeFromString, setAttributeFromString, setCacheBound, setComposedType, setCreationTime, setImplementation, setLinkedItems, setLinkedItems, setLinkedItems, setLinkedItems, setLinkedItems, setLinkedItems, setLinkedItems, setLinkedItems, setModificationTime, setNonInitialAttributes, setOwner, setPermissionsByMap, setTransientObject, setUseTA, suppressRelation, useTA, writeReplace

Methods inherited from class de.hybris.platform.util.BridgeAbstraction

setTenant

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Details

CatalogVersionSyncCronJob

public CatalogVersionSyncCronJob()

Method Details

isIgnoreErrors

public boolean isIgnoreErrors()

isChangeRecordingEnabled

public Boolean isChangeRecordingEnabled(SessionContext ctx)

Returns always false.

Overrides:

isChangeRecordingEnabled in class SyncItemCronJob

Returns:

the changeRecordingEnabled

setChangeRecordingEnabled

public void setChangeRecordingEnabled(SessionContext ctx,
 boolean enabled)

Disabled.

Overrides:

setChangeRecordingEnabled in class SyncItemCronJob

enabled - the changeRecordingEnabled

addPendingItem

public ItemSyncDescriptor addPendingItem(PK srcPK,
 PK tgtPK)

Adds a single schedule. If no target item pk is specified the sync job automatically checks for existing counterpart items using the unique key attributes.

Overrides:

addPendingItem in class SyncItemCronJob

Parameters:

srcPK - the source item pk

tgtPK - optionally the target item pk

addPendingItems

public void addPendingItems(List<PK[]> tokens)

Adds multiple schedules at once. Since schedules are written into media files this is the preferred (fastest) way.

Parameters:

tokens -

getPendingItems

@Deprecated(since="ages",
            forRemoval=false)
public Collection getPendingItems()

Deprecated.

since ages

Description copied from class: GeneratedSyncItemCronJob

Generated method - Getter of the SyncItemCronJob.pendingItems attribute.

Overrides:

getPendingItems in class GeneratedSyncItemCronJob

Returns:

the pendingItems

getFinishedItems

@Deprecated(since="ages",
            forRemoval=false)
public Collection getFinishedItems()

Deprecated.

since ages

Description copied from class: GeneratedSyncItemCronJob

Generated method - Getter of the SyncItemCronJob.finishedItems attribute.

Overrides:

getFinishedItems in class GeneratedSyncItemCronJob

Returns:

the finishedItems

createNewScheduleMedia

protected CatalogVersionSyncScheduleMedia createNewScheduleMedia()

getOriginalSyncScheduleList

public List<SyncSchedule> getOriginalSyncScheduleList()

The methods allows to get a SyncSchedule list from the first scheduled medias file (the original full sync list).

Returns:

sync schedule list from the first schedule media file, empty list if there is no sync schedule

getScheduleMedia

protected CatalogVersionSyncScheduleMedia getScheduleMedia(boolean create)

getFile

protected File getFile(CatalogVersionSyncScheduleMedia scheduleMedia)

createSyncScheduleReader

public SyncScheduleReader createSyncScheduleReader()

Creates a schedule reader provided that a current schedule media exists.

See Also:

• hasSchedules()

getDumpFileName

protected String getDumpFileName()

getDumpFileTempName

protected String getDumpFileTempName()

createScheduleWriter

protected SyncScheduleWriter createScheduleWriter(File file,
 boolean append,
 int count,
 int deadlockCount)

hasSchedules

public boolean hasSchedules()

Tells whether or not schedules items exists.

createDumpScheduleWriter

public SyncScheduleWriter createDumpScheduleWriter(SyncStatusHolder statusHandler)

Creates a new schedule writer to collect dumped schedules. Please note that these schedules are not stored until you call storeDumpedSchedules(SyncScheduleWriter)!

See Also:

• storeDumpedSchedules(SyncScheduleWriter)

getDumpFilesDir

protected String getDumpFilesDir()

recreateDumpWriter

protected SyncScheduleWriter recreateDumpWriter(int validDumpCount)

storeDumpedSchedules

public void storeDumpedSchedules(SyncScheduleWriter scheduleWriter)

Stores dumped schedules in a new schedule media given a SyncScheduleWriter created via createDumpScheduleWriter(SyncStatusHolder).

isLastDumpsDifferent

public boolean isLastDumpsDifferent()

createStatusHolder

public SyncStatusHolder createStatusHolder()

instantiateCronJobHistory

protected CatalogVersionSyncCronJobHistory instantiateCronJobHistory()
                                                              throws JaloGenericCreationException,
JaloAbstractTypeException

Overrides:

instantiateCronJobHistory in class CronJob

Throws:

JaloGenericCreationException

JaloAbstractTypeException