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 ChangeDetectionService	getChangeDetectionService()
protected StreamConfiguration	getStreamConfiguration(OutboundSyncStreamConfigurationModel deltaStream)
boolean	isAbortable()	Checks whether the execution is implemented abortable.
PerformResult	perform(OutboundSyncCronJobModel cronJob)	The execution body for a ServicelayerJob.
protected int	processChanges(OutboundSyncCronJobModel cronJob, OutboundSyncStreamConfigurationModel deltaStream)	Processes the changes from the given stream configuration
protected int	processChangesForContainer(OutboundSyncCronJobModel cronJob)	Process changes for all stream configurations in the container
void	setChangeDetectionService(ChangeDetectionService changeDetectionService)
void	setChangesCollectorFactory(ChangesCollectorFactory changesCollectorFactory)
void	setEventService(EventService eventService)
void	setGettableChangesCollectorProvider(GettableChangesCollectorProvider changesCollectorProvider)	Deprecated, for removal: This API element is subject to removal in a future version. use setChangesCollectorFactory(ChangesCollectorFactory) instead
void	setItemChangeSender(ItemChangeSender itemChangeSender)	Deprecated, for removal: This API element is subject to removal in a future version. not used anymore.
void	setJobRegister(@NotNull OutboundSyncJobRegister register)	Injects specific OutboundSyncJobRegister implementation.

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

clearAbortRequestedIfNeeded, 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

isAbortable

public boolean isAbortable()

Description copied from interface: JobPerformable

Checks whether the execution is implemented abortable.

Specified by:

isAbortable in interface JobPerformable<OutboundSyncCronJobModel>

Overrides:

isAbortable in class AbstractJobPerformable<OutboundSyncCronJobModel>

Returns:

true if the execution can be aborted

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.

processChangesForContainer

protected int processChangesForContainer(OutboundSyncCronJobModel cronJob)

Process changes for all stream configurations in the container

Parameters:

cronJob - a cron job processing changes

Returns:

number of changes processed by the job or 0, if there are not changes detected.

processChanges

protected int processChanges(OutboundSyncCronJobModel cronJob,
                             OutboundSyncStreamConfigurationModel deltaStream)

Processes the changes from the given stream configuration

Parameters:

cronJob - a cron job processing changes in the specified stream

deltaStream - a stream containing changes to be processed by the job

Returns:

number of changes processed for the specified stream or 0, if the stream has no changes detected.

getStreamConfiguration

protected StreamConfiguration getStreamConfiguration(OutboundSyncStreamConfigurationModel deltaStream)

getChangeDetectionService

protected ChangeDetectionService getChangeDetectionService()

setChangeDetectionService

public void setChangeDetectionService(ChangeDetectionService changeDetectionService)

setItemChangeSender

@Deprecated(since="1905.2003-CEP",
            forRemoval=true)
public void setItemChangeSender(ItemChangeSender itemChangeSender)

Deprecated, for removal: This API element is subject to removal in a future version.

not used anymore.

setGettableChangesCollectorProvider

@Deprecated(since="1905.2003-CEP",
            forRemoval=true)
public void setGettableChangesCollectorProvider(GettableChangesCollectorProvider changesCollectorProvider)

Deprecated, for removal: This API element is subject to removal in a future version.

use setChangesCollectorFactory(ChangesCollectorFactory) instead

setChangesCollectorFactory

public void setChangesCollectorFactory(ChangesCollectorFactory changesCollectorFactory)

setEventService

public void setEventService(EventService eventService)

setJobRegister

public void setJobRegister(@NotNull
                           @NotNull OutboundSyncJobRegister register)

Injects specific OutboundSyncJobRegister implementation.

Parameters:

register - an implementation to use