Package de.hybris.platform.outboundsync.job.impl

Class OutboundSyncCronJobPerformable

java.lang.Object

de.hybris.platform.servicelayer.cronjob.AbstractJobPerformable<OutboundSyncCronJobModel>

de.hybris.platform.outboundsync.job.impl.OutboundSyncCronJobPerformable

All Implemented Interfaces:

JobPerformable<OutboundSyncCronJobModel>

public class OutboundSyncCronJobPerformable
extends AbstractJobPerformable<OutboundSyncCronJobModel>

This JobPerformable collects the changes specified in the StreamConfiguration and send them out via the ItemChangeSender.

Field Summary

Fields inherited from class de.hybris.platform.servicelayer.cronjob.AbstractJobPerformable

flexibleSearchService, modelService, sessionService

Constructor Summary

Constructors

Constructor	Description
OutboundSyncCronJobPerformable()

Method Summary

Modifier and Type	Method	Description
protected java.util.stream.Stream<OutboundItemDTO>	collectChanges(OutboundSyncStreamConfigurationModel deltaStream)	Collects the changes from the given stream configuration
protected java.util.List<OutboundItemDTO>	collectChangesFromConfigurations(OutboundSyncStreamConfigurationContainerModel streamConfigurationContainer)	Collect changes from all the stream configurations
protected ChangeDetectionService	getChangeDetectionService()
protected GettableChangesCollectorProvider	getGettableChangesCollectorProvider()
protected ItemChangeSender	getItemChangeSender()
protected StreamConfiguration	getStreamConfiguration(OutboundSyncStreamConfigurationModel deltaStream)
PerformResult	perform(OutboundSyncCronJobModel cronJob)	The execution body for a ServicelayerJob.
void	setChangeDetectionService(ChangeDetectionService changeDetectionService)
void	setGettableChangesCollectorProvider(GettableChangesCollectorProvider changesCollectorProvider)
void	setItemChangeSender(ItemChangeSender itemChangeSender)

Methods inherited from class de.hybris.platform.servicelayer.cronjob.AbstractJobPerformable

clearAbortRequestedIfNeeded, isAbortable, isPerformable, setFlexibleSearchService, setModelService, setSessionService

Methods inherited from class java.lang.Object

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

Constructor Detail

OutboundSyncCronJobPerformable

public OutboundSyncCronJobPerformable()

Method Detail

perform

public PerformResult perform(OutboundSyncCronJobModel cronJob)

Description copied from interface: JobPerformable

The execution body for a ServicelayerJob. Implement here your execution logic. It can be called synchronous or asynchronous. So be aware of thread-safety. Method will return a result object saying if the execution has reached end and if it was successful.

Specified by:

perform in interface JobPerformable<OutboundSyncCronJobModel>

Specified by:

perform in class AbstractJobPerformable<OutboundSyncCronJobModel>

Parameters:

cronJob - the related CronJob in whose context the execution will be performed.

Returns:

a PerformResult that indicates whether the execution was successfully executed or not and has finished or not.

collectChangesFromConfigurations

protected java.util.List<OutboundItemDTO> collectChangesFromConfigurations(OutboundSyncStreamConfigurationContainerModel streamConfigurationContainer)

Collect changes from all the stream configurations

Parameters:

streamConfigurationContainer - Container with all the stream configurations

Returns:

Changes from all the stream configurations

collectChanges

protected java.util.stream.Stream<OutboundItemDTO> collectChanges(OutboundSyncStreamConfigurationModel deltaStream)

Collects the changes from the given stream configuration

Parameters:

deltaStream - Collect the changes for this stream configuration

Returns:

List of changes

getStreamConfiguration

protected StreamConfiguration getStreamConfiguration(OutboundSyncStreamConfigurationModel deltaStream)

getChangeDetectionService

protected ChangeDetectionService getChangeDetectionService()

setChangeDetectionService

public void setChangeDetectionService(ChangeDetectionService changeDetectionService)

getItemChangeSender

protected ItemChangeSender getItemChangeSender()

setItemChangeSender

public void setItemChangeSender(ItemChangeSender itemChangeSender)

getGettableChangesCollectorProvider

protected GettableChangesCollectorProvider getGettableChangesCollectorProvider()

setGettableChangesCollectorProvider

public void setGettableChangesCollectorProvider(GettableChangesCollectorProvider changesCollectorProvider)