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

Class DefaultChangesCollectorFactory

java.lang.Object

de.hybris.platform.outboundsync.job.impl.DefaultChangesCollectorFactory

All Implemented Interfaces:

ChangesCollectorFactory

public class DefaultChangesCollectorFactory
extends Object
implements ChangesCollectorFactory

Streaming changes collector implementation for the factory.

Constructor Summary

Constructors

Constructor	Description
DefaultChangesCollectorFactory()

Method Summary

Modifier and Type	Method	Description
CountingChangesCollector	createCountingCollector(OutboundSyncCronJobModel cronJob, OutboundSyncStreamConfigurationModel stream)	Returns a newly created instance of CountingChangesCollector.
void	setFilteringService(FilteringService filteringService)
void	setItemChangeSender(ItemChangeSender itemChangeSender)

Methods inherited from class java.lang.Object

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

Constructor Details

DefaultChangesCollectorFactory

public DefaultChangesCollectorFactory()

Method Details

createCountingCollector

public CountingChangesCollector createCountingCollector(OutboundSyncCronJobModel cronJob,
 OutboundSyncStreamConfigurationModel stream)

Description copied from interface: ChangesCollectorFactory

Returns a newly created instance of CountingChangesCollector.

Specified by:

createCountingCollector in interface ChangesCollectorFactory

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)

setFilteringService

public void setFilteringService(FilteringService filteringService)