Package de.hybris.y2ysync.services.impl

Class DefaultSyncExecutionService

java.lang.Object

de.hybris.y2ysync.services.impl.DefaultSyncExecutionService

All Implemented Interfaces:

SyncExecutionService

public class DefaultSyncExecutionService
extends java.lang.Object
implements SyncExecutionService

Nested Class Summary

Nested classes/interfaces inherited from interface de.hybris.y2ysync.services.SyncExecutionService

SyncExecutionService.ExecutionMode

Constructor Summary

Constructors

Constructor	Description
DefaultSyncExecutionService()

Method Summary

Modifier and Type	Method	Description
Y2YSyncJobModel	createSyncJobForDataHub(java.lang.String code, Y2YStreamConfigurationContainerModel container)	Creates sync job configured for DataHub sync for a given container.
Y2YSyncJobModel	createSyncJobForDataHub(java.lang.String code, Y2YStreamConfigurationContainerModel container, java.lang.String dataHubUrl)	Creates sync job configured for DataHub sync for a given container with custom dataHubUrl.
Y2YSyncJobModel	createSyncJobForZip(java.lang.String code, Y2YStreamConfigurationContainerModel container)	Creates sync job configured for Zip sync for a given container.
java.util.Collection<Y2YSyncJobModel>	getAllSyncJobs()	Returns collection of all sync jobs in the system.
java.util.Collection<Y2YSyncJobModel>	getSyncJobsForContainer(Y2YStreamConfigurationContainerModel container)	Returns collection of all sync jobs for given Y2YStreamConfigurationContainer.
void	setCronJobService(CronJobService cronJobService)
void	setFlexibleSearchService(FlexibleSearchService flexibleSearchService)
void	setModelService(ModelService modelService)
Y2YSyncCronJobModel	startSync(Y2YSyncJobModel job, SyncExecutionService.ExecutionMode executionMode)	Starts synchronization using Y2YSyncJobModel.
Y2YSyncCronJobModel	startSync(java.lang.String jobCode, SyncExecutionService.ExecutionMode executionMode)	Starts synchronization using Y2YSyncJobModel defined by a jobCode.

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultSyncExecutionService

public DefaultSyncExecutionService()

Method Detail

startSync

public Y2YSyncCronJobModel startSync(java.lang.String jobCode,
                                     SyncExecutionService.ExecutionMode executionMode)

Description copied from interface: SyncExecutionService

Starts synchronization using Y2YSyncJobModel defined by a jobCode. This method creates instance of Y2YSyncCronJobModel connected to a given Y2YSyncCronJobModel under the hood each time it is called.

Specified by:

startSync in interface SyncExecutionService

Parameters:

jobCode - Code of the Y2YSyncJobModel used for synchronization

executionMode - ExecutionMode (SYNC or ASYNC)

startSync

public Y2YSyncCronJobModel startSync(Y2YSyncJobModel job,
                                     SyncExecutionService.ExecutionMode executionMode)

Description copied from interface: SyncExecutionService

Starts synchronization using Y2YSyncJobModel. This method creates instance of Y2YSyncCronJobModel connected to a given Y2YSyncCronJobModel under the hood each time it is called.

Specified by:

startSync in interface SyncExecutionService

Parameters:

job - instance of the Y2YSyncJobModel used for synchronization

executionMode - ExecutionMode (SYNC or ASYNC)

getAllSyncJobs

public java.util.Collection<Y2YSyncJobModel> getAllSyncJobs()

Description copied from interface: SyncExecutionService

Returns collection of all sync jobs in the system.

Specified by:

getAllSyncJobs in interface SyncExecutionService

getSyncJobsForContainer

public java.util.Collection<Y2YSyncJobModel> getSyncJobsForContainer(Y2YStreamConfigurationContainerModel container)

Description copied from interface: SyncExecutionService

Returns collection of all sync jobs for given Y2YStreamConfigurationContainer.

Specified by:

getSyncJobsForContainer in interface SyncExecutionService

createSyncJobForDataHub

public Y2YSyncJobModel createSyncJobForDataHub(java.lang.String code,
                                               Y2YStreamConfigurationContainerModel container)

Description copied from interface: SyncExecutionService

Creates sync job configured for DataHub sync for a given container. Models are not saved.

Specified by:

createSyncJobForDataHub in interface SyncExecutionService

createSyncJobForDataHub

public Y2YSyncJobModel createSyncJobForDataHub(java.lang.String code,
                                               Y2YStreamConfigurationContainerModel container,
                                               java.lang.String dataHubUrl)

Description copied from interface: SyncExecutionService

Creates sync job configured for DataHub sync for a given container with custom dataHubUrl. Models are not saved.

Specified by:

createSyncJobForDataHub in interface SyncExecutionService

createSyncJobForZip

public Y2YSyncJobModel createSyncJobForZip(java.lang.String code,
                                           Y2YStreamConfigurationContainerModel container)

Description copied from interface: SyncExecutionService

Creates sync job configured for Zip sync for a given container.

Specified by:

createSyncJobForZip in interface SyncExecutionService

setModelService

public void setModelService(ModelService modelService)

setCronJobService

public void setCronJobService(CronJobService cronJobService)

setFlexibleSearchService

public void setFlexibleSearchService(FlexibleSearchService flexibleSearchService)