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>
ThisJobPerformablecollects the changes specified in theStreamConfigurationand send them out via theItemChangeSender.
-
-
Field Summary
-
Fields inherited from class de.hybris.platform.servicelayer.cronjob.AbstractJobPerformable
flexibleSearchService, modelService, sessionService
-
-
Constructor Summary
Constructors Constructor Description OutboundSyncCronJobPerformable()
-
Method Summary
-
Methods inherited from class de.hybris.platform.servicelayer.cronjob.AbstractJobPerformable
clearAbortRequestedIfNeeded, isAbortable, isPerformable, setFlexibleSearchService, setModelService, setSessionService
-
-
-
-
Method Detail
-
perform
public PerformResult perform(OutboundSyncCronJobModel cronJob)
Description copied from interface:JobPerformableThe execution body for aServicelayerJob. 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:
performin interfaceJobPerformable<OutboundSyncCronJobModel>- Specified by:
performin classAbstractJobPerformable<OutboundSyncCronJobModel>- Parameters:
cronJob- the related CronJob in whose context the execution will be performed.- Returns:
- a
PerformResultthat indicates whether theexecutionwas 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)
-
-