de.hybris.deltadetection.impl

Class DefaultChangeDetectionService

java.lang.Object

de.hybris.deltadetection.impl.DefaultChangeDetectionService

All Implemented Interfaces:

ChangeDetectionService

public class DefaultChangeDetectionService
extends java.lang.Object
implements ChangeDetectionService

Default Implementation of change detection service

Constructor Summary

Constructors

Constructor and Description
DefaultChangeDetectionService()

Method Summary

Modifier and Type	Method and Description
void	collectChangesForType(ComposedTypeModel composedType, StreamConfiguration configuration, ChangesCollector collector) Detects all kind of changes (NEW, MODIFIED, DELETED) on items for the given composed type.
void	collectChangesForType(ComposedTypeModel composedType, java.lang.String streamId, ChangesCollector collector) Detects all kind of changes (NEW, MODIFIED, DELETED) on items for the given composed type.
void	consumeChanges(java.util.List<ItemChangeDTO> allChanges) Consumes all given changes.
protected java.util.concurrent.Callable<java.lang.Integer>	createConsumeBatchCallable(java.lang.String streamId, java.util.List<ItemChangeDTO> changes, int maxRetries)
void	deleteItemVersionMarkersForStream(java.lang.String streamId) Deletes all item version markers belonging to the stream
ItemChangeDTO	getChangeForExistingItem(ItemModel item, java.lang.String streamId) Detects change for a given existing item and stream.
ItemChangeDTO	getChangeForRemovedItem(PK pk, java.lang.String streamId) Detects potential change for a an not existing item - (change type 'DELETED'), stored under ItemVersionMarker referencing given item pk.
java.util.List<ItemChangeDTO>	getChangesForRemovedItems(java.lang.String streamId) Detects changes for all items, which doesn't exist anymore (change type 'DELETED'), stored under ItemVersionMarker referencing the not existing item pks.
protected java.util.List<java.util.concurrent.Callable<java.lang.Integer>>	prepareBatchExecutionCallables(java.util.List<ItemChangeDTO> allChanges)
void	resetStream(java.lang.String streamId) Resets the stream.
void	setFlexibleSearchService(FlexibleSearchService flexibleSearchService)
void	setModelService(ModelService modelService)
void	setTypeService(TypeService typeService)

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultChangeDetectionService

public DefaultChangeDetectionService()

Method Detail

getChangeForExistingItem

public ItemChangeDTO getChangeForExistingItem(ItemModel item,
                                              java.lang.String streamId)

Description copied from interface: ChangeDetectionService

Detects change for a given existing item and stream. Finds changes of change type 'NEW' or "MODIFIED'.

Specified by:

getChangeForExistingItem in interface ChangeDetectionService

Parameters:

item - the item to be checked

streamId - the streamId for which the changes should be detect

Returns:

ItemChangeDTO Object containing all the information about the change

getChangeForRemovedItem

public ItemChangeDTO getChangeForRemovedItem(PK pk,
                                             java.lang.String streamId)

Description copied from interface: ChangeDetectionService

Detects potential change for a an not existing item - (change type 'DELETED'), stored under ItemVersionMarker referencing given item pk.

Specified by:

getChangeForRemovedItem in interface ChangeDetectionService

Parameters:

pk - the pk of the item to be checked

streamId - the streamId for which the change should be detect

Returns:

ItemChangeDTO Object containing all the information about the change

getChangesForRemovedItems

public java.util.List<ItemChangeDTO> getChangesForRemovedItems(java.lang.String streamId)

Description copied from interface: ChangeDetectionService

Detects changes for all items, which doesn't exist anymore (change type 'DELETED'), stored under ItemVersionMarker referencing the not existing item pks.

Specified by:

getChangesForRemovedItems in interface ChangeDetectionService

Parameters:

streamId - the streamId for which the change should be detect

Returns:

List of ItemChangeDTO Objects containing all the information about the changes

collectChangesForType

public void collectChangesForType(ComposedTypeModel composedType,
                                  java.lang.String streamId,
                                  ChangesCollector collector)

Description copied from interface: ChangeDetectionService

Detects all kind of changes (NEW, MODIFIED, DELETED) on items for the given composed type.

Specified by:

collectChangesForType in interface ChangeDetectionService

Parameters:

composedType - the type for which the change detection should be executed (including subtypes)

streamId - the streamId for which the change should be detect

collector - responsible for collecting the changes in specified way, e.g. store them in memory or generate csv file.

collectChangesForType

public void collectChangesForType(ComposedTypeModel composedType,
                                  StreamConfiguration configuration,
                                  ChangesCollector collector)

Description copied from interface: ChangeDetectionService

Detects all kind of changes (NEW, MODIFIED, DELETED) on items for the given composed type.

Specified by:

collectChangesForType in interface ChangeDetectionService

Parameters:

composedType - the type for which the change detection should be executed (including subtypes)

configuration - the stream configuration defining which item should be included into the stream.

collector - responsible for collecting the changes in specified way, e.g. store them in memory or generate csv file.

See Also:

StreamConfiguration

consumeChanges

public void consumeChanges(java.util.List<ItemChangeDTO> allChanges)

Description copied from interface: ChangeDetectionService

Consumes all given changes. it Means, for the changes of change type NEW - a new ItemVersionMarker is created, in case of change type MODIFIED - the item version marker is updated properly and in case of change type DELETED - the ItemVersionMarker is removed. The stream for which the changes will be consumed is defined inside the given ItemChangeDTO objects

Specified by:

consumeChanges in interface ChangeDetectionService

Parameters:

allChanges - list of the changes to be consumed.

prepareBatchExecutionCallables

protected java.util.List<java.util.concurrent.Callable<java.lang.Integer>> prepareBatchExecutionCallables(java.util.List<ItemChangeDTO> allChanges)

createConsumeBatchCallable

protected java.util.concurrent.Callable<java.lang.Integer> createConsumeBatchCallable(java.lang.String streamId,
                                                                                      java.util.List<ItemChangeDTO> changes,
                                                                                      int maxRetries)

deleteItemVersionMarkersForStream

public void deleteItemVersionMarkersForStream(java.lang.String streamId)

Description copied from interface: ChangeDetectionService

Deletes all item version markers belonging to the stream

Specified by:

deleteItemVersionMarkersForStream in interface ChangeDetectionService

Parameters:

streamId - stream id for which item version markers should be deleted

resetStream

public void resetStream(java.lang.String streamId)

Description copied from interface: ChangeDetectionService

Resets the stream. It means that all ItemVersionMarkers with status DELETED will change their status to ACTIVE and all the ItemVersionMarkers with status ACTIVE will have their versionTS set to the beginning of Unix Epoch time (1 January 1970).

Specified by:

resetStream in interface ChangeDetectionService

Parameters:

streamId - stream id for which item version markers should be reset

setFlexibleSearchService

public void setFlexibleSearchService(FlexibleSearchService flexibleSearchService)

setModelService

public void setModelService(ModelService modelService)

setTypeService

public void setTypeService(TypeService typeService)