Package com.broadleafcommerce.datafeed.service

Class DefaultIncrementalDataFeedEntityUpdateRecordService<P extends IncrementalDataFeedEntityUpdateRecord>

java.lang.Object

com.broadleafcommerce.data.tracking.core.service.BaseCrudEntityService<P>

com.broadleafcommerce.data.tracking.core.service.BaseRsqlCrudEntityService<P>

com.broadleafcommerce.datafeed.service.DefaultIncrementalDataFeedEntityUpdateRecordService<P>

Type Parameters:

P - business/projection type of IncrementalDataFeedEntityUpdateRecord

All Implemented Interfaces:

com.broadleafcommerce.data.tracking.core.service.CrudEntityService<P>, com.broadleafcommerce.data.tracking.core.service.RsqlCrudEntityService<P>, IncrementalDataFeedEntityUpdateRecordService<P>

public class DefaultIncrementalDataFeedEntityUpdateRecordService<P extends IncrementalDataFeedEntityUpdateRecord>
extends com.broadleafcommerce.data.tracking.core.service.BaseRsqlCrudEntityService<P>
implements IncrementalDataFeedEntityUpdateRecordService<P>

Default implementation of IncrementalDataFeedEntityUpdateRecordService

Constructor Summary

Constructors

Constructor	Description
DefaultIncrementalDataFeedEntityUpdateRecordService(IncrementalDataFeedEntityUpdateRecordRepository<com.broadleafcommerce.data.tracking.core.Trackable> repository, com.broadleafcommerce.data.tracking.core.service.RsqlCrudEntityHelper helper)

Method Summary

Modifier and Type	Method	Description
protected IncrementalDataFeedEntityUpdateRecordRepository<com.broadleafcommerce.data.tracking.core.Trackable>	getRepository()
int	hardDeleteAllByProcessExecutionId(String dataFeedProcessExecutionId, com.broadleafcommerce.data.tracking.core.context.ContextInfo contextInfo)	Atomically finds and hard-deletes IncrementalDataFeedEntityUpdateRecord instances belonging to the given DataFeedProcessExecution.
int	setExecutionIdForUnackedRecords(String dataFeedProcessId, String dataFeedProcessExecutionId, com.broadleafcommerce.data.tracking.core.context.ContextInfo contextInfo)	Atomically finds and sets IncrementalDataFeedEntityUpdateRecord.getDataFeedProcessExecutionId() on all IncrementalDataFeedEntityUpdateRecord entities where it is currently null.

Methods inherited from class com.broadleafcommerce.data.tracking.core.service.BaseRsqlCrudEntityService

getRsqlHelper, readAll, readAll, readAll, readAll

Methods inherited from class com.broadleafcommerce.data.tracking.core.service.BaseCrudEntityService

convertFromPersistentDomain, convertToPersistentDomain, create, createAll, createAllAllowingPartialSuccess, delete, getHelper, getSortPositionStrategy, readAll, readAll, readAll, readAllByContextId, readByContextId, replace, replaceAll, replaceAllAllowingPartialSuccess, setSortPositionStrategy, update, updateAll, updateAllAllowingPartialSuccess, updateSort

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.broadleafcommerce.data.tracking.core.service.CrudEntityService

create, createAll, createAllAllowingPartialSuccess, delete, readAll, readAll, readAll, readAllByContextId, readByContextId, replace, replaceAll, replaceAllAllowingPartialSuccess, update, updateAll, updateAllAllowingPartialSuccess, updateSort

Methods inherited from interface com.broadleafcommerce.data.tracking.core.service.RsqlCrudEntityService

readAll, readAll, readAll, readAll

Constructor Details

DefaultIncrementalDataFeedEntityUpdateRecordService

public DefaultIncrementalDataFeedEntityUpdateRecordService(IncrementalDataFeedEntityUpdateRecordRepository<com.broadleafcommerce.data.tracking.core.Trackable> repository,
 com.broadleafcommerce.data.tracking.core.service.RsqlCrudEntityHelper helper)

Method Details

setExecutionIdForUnackedRecords

public int setExecutionIdForUnackedRecords(String dataFeedProcessId,
 String dataFeedProcessExecutionId,
 @Nullable
 com.broadleafcommerce.data.tracking.core.context.ContextInfo contextInfo)

Description copied from interface: IncrementalDataFeedEntityUpdateRecordService

Atomically finds and sets IncrementalDataFeedEntityUpdateRecord.getDataFeedProcessExecutionId() on all IncrementalDataFeedEntityUpdateRecord entities where it is currently null.

Specified by:

setExecutionIdForUnackedRecords in interface IncrementalDataFeedEntityUpdateRecordService<P extends IncrementalDataFeedEntityUpdateRecord>

Parameters:

dataFeedProcessId - the value of IncrementalDataFeedEntityUpdateRecord.getDataFeedProcessId() to filter results by

dataFeedProcessExecutionId - the new value to set for IncrementalDataFeedEntityUpdateRecord.getDataFeedProcessExecutionId()

contextInfo - context information around multitenant state

Returns:

the number of records that were updated

hardDeleteAllByProcessExecutionId

public int hardDeleteAllByProcessExecutionId(String dataFeedProcessExecutionId,
 @Nullable
 com.broadleafcommerce.data.tracking.core.context.ContextInfo contextInfo)

Description copied from interface: IncrementalDataFeedEntityUpdateRecordService

Atomically finds and hard-deletes IncrementalDataFeedEntityUpdateRecord instances belonging to the given DataFeedProcessExecution.

Specified by:

hardDeleteAllByProcessExecutionId in interface IncrementalDataFeedEntityUpdateRecordService<P extends IncrementalDataFeedEntityUpdateRecord>

Parameters:

dataFeedProcessExecutionId - the value of IncrementalDataFeedEntityUpdateRecord.getDataFeedProcessExecutionId() to match

contextInfo - context information around multitenant state

Returns:

the number of records that were deleted

getRepository

protected IncrementalDataFeedEntityUpdateRecordRepository<com.broadleafcommerce.data.tracking.core.Trackable> getRepository()

Overrides:

getRepository in class com.broadleafcommerce.data.tracking.core.service.BaseCrudEntityService<P extends IncrementalDataFeedEntityUpdateRecord>