Class DefaultChangesCollectorFactory
- java.lang.Object
-
- de.hybris.platform.outboundsync.job.impl.DefaultChangesCollectorFactory
-
- All Implemented Interfaces:
ChangesCollectorFactory
public class DefaultChangesCollectorFactory extends java.lang.Object implements ChangesCollectorFactory
Streaming changes collector implementation for the factory.
-
-
Constructor Summary
Constructors Constructor Description DefaultChangesCollectorFactory()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description CountingChangesCollectorcreateCountingCollector(OutboundSyncCronJobModel cronJob, OutboundSyncStreamConfigurationModel stream)Returns a newly created instance ofCountingChangesCollector.voidsetItemChangeSender(ItemChangeSender itemChangeSender)
-
-
-
Method Detail
-
createCountingCollector
public CountingChangesCollector createCountingCollector(OutboundSyncCronJobModel cronJob, OutboundSyncStreamConfigurationModel stream)
Description copied from interface:ChangesCollectorFactoryReturns a newly created instance ofCountingChangesCollector.- Specified by:
createCountingCollectorin interfaceChangesCollectorFactory- Parameters:
cronJob- context job. A cron job that is processing item changes.stream- the stream configuration to use in the collector- Returns:
- new instance of changes collector
-
setItemChangeSender
public void setItemChangeSender(ItemChangeSender itemChangeSender)
-
-