de.hybris.platform.catalog.synchronization

Class DefaultCatalogSynchronizationService

java.lang.Object

de.hybris.platform.catalog.synchronization.DefaultCatalogSynchronizationService

All Implemented Interfaces:

CatalogSynchronizationService

public class DefaultCatalogSynchronizationService
extends java.lang.Object
implements CatalogSynchronizationService

Constructor Summary

Constructors

Constructor and Description
DefaultCatalogSynchronizationService()

Method Summary

Modifier and Type	Method and Description
protected void	addScheduleFromConfig(SyncItemCronJobModel cronJob, SyncConfig config)
protected SyncConfig	cloneSyncConfig(SyncConfig givenSyncConfig)
protected SyncItemCronJobModel	createSyncCronJob(SyncItemJobModel job)
protected CatalogVersionSyncJobModel	createSyncJob(CatalogVersionModel source, CatalogVersionModel target)
protected CatalogVersionSyncJobModel	createSyncJob(CatalogVersionModel source, CatalogVersionModel target, int numberOfThreads)
java.util.List<ItemModel>	getApplicableItems(java.util.List<ItemModel> inputItems, SyncItemJobModel syncItemJob) Filters given items returning only the ones being applicable to the given sync job.
protected java.lang.Integer	getMaxThreads()
ItemModel	getSynchronizationSourceFor(SyncItemJobModel theSyncJob, ItemModel targetItem) Returns the counterpart for the target item against given sync job theSyncJob.
ItemSyncTimestampModel	getSynchronizationSourceTimestampFor(SyncItemJobModel theSyncJob, ItemModel source) Returns the existing ItemSyncTimestampModel for the source item in the scope of the given sync job.
ItemModel	getSynchronizationTargetFor(SyncItemJobModel theSyncJob, ItemModel sourceItem) Returns the counterpart for the source item against given sync job theSyncJob.
ItemSyncTimestampModel	getSynchronizationTargetTimestampFor(SyncItemJobModel theSyncJob, ItemModel target) Returns the existing ItemSyncTimestampModel for the target item in the scope of the given sync job.
SyncItemJobModel	getSyncJob(CatalogVersionModel source, CatalogVersionModel target, java.lang.String qualifier) Returns the publication rule (as SyncItemJobModel item) between a specified source catalog version and target catalog version.
boolean	isInProgress(SyncItemJobModel theSyncJob) Checks whether the given givenSyncJob is currently in progress.
java.util.Collection<SyncResult>	lookupCurrentSynchronizations(SyncItemJobModel theSyncJob) Returns the current executions for the given theSyncJob.
java.util.List<SyncResult>	performSynchronization(java.util.List<ItemModel> givenItems, java.util.List<SyncItemJobModel> syncItemJobs, SyncConfig syncConfig) Performs the synchronization for given items against given sync jobs.
SyncResult	performSynchronization(java.util.List<ItemModel> givenItems, SyncItemJobModel syncItemJob, SyncConfig syncConfig) Performs the synchronization for given items.
protected SyncConfig	scheduleItemsWithConfig(SyncConfig syncConfig, SyncItemJobModel syncJob, java.util.List<ItemModel> applicableItems)
void	setCatalogTypeService(CatalogTypeService catalogTypeService)
void	setCronJobService(CronJobService cronJobService)
void	setFlexibleSearchService(FlexibleSearchService flexibleSearchService)
void	setItemSyncTimestampDao(ItemSyncTimestampDao itemSyncTimestampDao)
void	setModelService(ModelService modelService)
void	setSyncJobApplicableTypesStrategy(SyncJobApplicableTypesStrategy syncJobApplicableTypesStrategy)
SyncResult	synchronize(SyncItemJobModel syncJob, SyncConfig syncConfig) Starts synchronization for an existing SyncItemJobModel.
void	synchronizeFully(CatalogVersionModel source, CatalogVersionModel target) For the given catalog version pair a new CatalogVersionSyncJobModel is being created configured to sync all default catalog item types.
void	synchronizeFully(CatalogVersionModel source, CatalogVersionModel target, int numberOfThreads) For the given catalog version pair a new CatalogVersionSyncJobModel is being created configured to sync all default catalog item types.
void	synchronizeFullyInBackground(CatalogVersionModel source, CatalogVersionModel target) For the given catalog version pair a new CatalogVersionSyncJobModel is being created configured to sync all default catalog item types.

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultCatalogSynchronizationService

public DefaultCatalogSynchronizationService()

Method Detail

synchronizeFully

public void synchronizeFully(CatalogVersionModel source,
                             CatalogVersionModel target)

Description copied from interface: CatalogSynchronizationService

For the given catalog version pair a new CatalogVersionSyncJobModel is being created configured to sync all default catalog item types. The actual sync process is backed by a also new CatalogVersionSyncCronJobModel which is performed synchronously.

Specified by:

synchronizeFully in interface CatalogSynchronizationService

synchronizeFully

public void synchronizeFully(CatalogVersionModel source,
                             CatalogVersionModel target,
                             int numberOfThreads)

Description copied from interface: CatalogSynchronizationService

For the given catalog version pair a new CatalogVersionSyncJobModel is being created configured to sync all default catalog item types. The actual sync process is backed by a also new CatalogVersionSyncCronJobModel which is started synchronously.

Specified by:

synchronizeFully in interface CatalogSynchronizationService

numberOfThreads - specifies the number of sync workers to be used - overrides the number configured in catalog.sync.workers

synchronizeFullyInBackground

public void synchronizeFullyInBackground(CatalogVersionModel source,
                                         CatalogVersionModel target)

Description copied from interface: CatalogSynchronizationService

For the given catalog version pair a new CatalogVersionSyncJobModel is being created configured to sync all default catalog item types. The actual sync process is backed by a also new CatalogVersionSyncCronJobModel which is started asynchronously.

Specified by:

synchronizeFullyInBackground in interface CatalogSynchronizationService

synchronize

public SyncResult synchronize(SyncItemJobModel syncJob,
                              SyncConfig syncConfig)

Description copied from interface: CatalogSynchronizationService

Starts synchronization for an existing SyncItemJobModel. The configuration parameter allows to configure/override a number of synchronization job settings. The returned SyncResult gives both access to the execution result or, in case the process was started asynchronously, to observe the running process

Specified by:

synchronize in interface CatalogSynchronizationService

performSynchronization

public java.util.List<SyncResult> performSynchronization(java.util.List<ItemModel> givenItems,
                                                         java.util.List<SyncItemJobModel> syncItemJobs,
                                                         SyncConfig syncConfig)

Description copied from interface: CatalogSynchronizationService

Performs the synchronization for given items against given sync jobs. Note that for each job the list of items is being filtered to schedule only the ones which are actually applicable (being compatible with the job's root type collection). For influencing the sync behavior a sync config object can be passed, e.g. for controlling the level of multi-threading.

Specified by:

performSynchronization in interface CatalogSynchronizationService

scheduleItemsWithConfig

protected SyncConfig scheduleItemsWithConfig(SyncConfig syncConfig,
                                             SyncItemJobModel syncJob,
                                             java.util.List<ItemModel> applicableItems)

getSyncJob

public SyncItemJobModel getSyncJob(CatalogVersionModel source,
                                   CatalogVersionModel target,
                                   java.lang.String qualifier)

Description copied from interface: CatalogSynchronizationService

Returns the publication rule (as SyncItemJobModel item) between a specified source catalog version and target catalog version.

Specified by:

getSyncJob in interface CatalogSynchronizationService

performSynchronization

public SyncResult performSynchronization(java.util.List<ItemModel> givenItems,
                                         SyncItemJobModel syncItemJob,
                                         SyncConfig syncConfig)

Description copied from interface: CatalogSynchronizationService

Performs the synchronization for given items. Note that the list of items is being filtered to schedule only the ones which are actually applicable (being compatible with the job's root type collection). For influencing the sync behavior a sync config object can be passed, e.g. for controlling the level of multi-threading.

Specified by:

performSynchronization in interface CatalogSynchronizationService

getApplicableItems

public java.util.List<ItemModel> getApplicableItems(java.util.List<ItemModel> inputItems,
                                                    SyncItemJobModel syncItemJob)

Description copied from interface: CatalogSynchronizationService

Filters given items returning only the ones being applicable to the given sync job. Being applicable means whether or not an item is compatible to the job's root type collection and whether it belongs to the specified catalog version.

Specified by:

getApplicableItems in interface CatalogSynchronizationService

isInProgress

public boolean isInProgress(SyncItemJobModel theSyncJob)

Description copied from interface: CatalogSynchronizationService

Checks whether the given givenSyncJob is currently in progress.

Specified by:

isInProgress in interface CatalogSynchronizationService

lookupCurrentSynchronizations

public java.util.Collection<SyncResult> lookupCurrentSynchronizations(SyncItemJobModel theSyncJob)

Description copied from interface: CatalogSynchronizationService

Returns the current executions for the given theSyncJob.

Specified by:

lookupCurrentSynchronizations in interface CatalogSynchronizationService

getSynchronizationSourceTimestampFor

public ItemSyncTimestampModel getSynchronizationSourceTimestampFor(SyncItemJobModel theSyncJob,
                                                                   ItemModel source)

Description copied from interface: CatalogSynchronizationService

Returns the existing ItemSyncTimestampModel for the source item in the scope of the given sync job. In case of the item never been synchronized before NULL is returned.

Specified by:

getSynchronizationSourceTimestampFor in interface CatalogSynchronizationService

getSynchronizationTargetTimestampFor

public ItemSyncTimestampModel getSynchronizationTargetTimestampFor(SyncItemJobModel theSyncJob,
                                                                   ItemModel target)

Description copied from interface: CatalogSynchronizationService

Returns the existing ItemSyncTimestampModel for the target item in the scope of the given sync job. In case of the original source item being deleted this methods will return NULL.

Specified by:

getSynchronizationTargetTimestampFor in interface CatalogSynchronizationService

getSynchronizationSourceFor

public ItemModel getSynchronizationSourceFor(SyncItemJobModel theSyncJob,
                                             ItemModel targetItem)

Description copied from interface: CatalogSynchronizationService

Returns the counterpart for the target item against given sync job theSyncJob.

Specified by:

getSynchronizationSourceFor in interface CatalogSynchronizationService

getSynchronizationTargetFor

public ItemModel getSynchronizationTargetFor(SyncItemJobModel theSyncJob,
                                             ItemModel sourceItem)

Description copied from interface: CatalogSynchronizationService

Returns the counterpart for the source item against given sync job theSyncJob.

Specified by:

getSynchronizationTargetFor in interface CatalogSynchronizationService

addScheduleFromConfig

protected void addScheduleFromConfig(SyncItemCronJobModel cronJob,
                                     SyncConfig config)

createSyncJob

protected CatalogVersionSyncJobModel createSyncJob(CatalogVersionModel source,
                                                   CatalogVersionModel target)

createSyncJob

protected CatalogVersionSyncJobModel createSyncJob(CatalogVersionModel source,
                                                   CatalogVersionModel target,
                                                   int numberOfThreads)

createSyncCronJob

protected SyncItemCronJobModel createSyncCronJob(SyncItemJobModel job)

cloneSyncConfig

protected SyncConfig cloneSyncConfig(SyncConfig givenSyncConfig)

getMaxThreads

protected java.lang.Integer getMaxThreads()

setCronJobService

public void setCronJobService(CronJobService cronJobService)

setModelService

public void setModelService(ModelService modelService)

setItemSyncTimestampDao

public void setItemSyncTimestampDao(ItemSyncTimestampDao itemSyncTimestampDao)

setSyncJobApplicableTypesStrategy

public void setSyncJobApplicableTypesStrategy(SyncJobApplicableTypesStrategy syncJobApplicableTypesStrategy)

setCatalogTypeService

public void setCatalogTypeService(CatalogTypeService catalogTypeService)

setFlexibleSearchService

public void setFlexibleSearchService(FlexibleSearchService flexibleSearchService)