Package com.broadleafcommerce.datafeed.service.manager

Class IncrementalDataFeedEntityUpdateManager

java.lang.Object

com.broadleafcommerce.datafeed.service.manager.IncrementalDataFeedEntityUpdateManager

public class IncrementalDataFeedEntityUpdateManager
extends Object

Responsible for high-level operations relating to IncrementalDataFeedEntityUpdateEvent and IncrementalDataFeedEntityUpdateRecord.

While IncrementalDataFeedEntityUpdateRecordService is in charge of CRUD-related operations on IncrementalDataFeedEntityUpdateRecord, this service is a higher-level abstraction that performs the surrounding logic of processing incremental events. It internally delegates to IncrementalDataFeedEntityUpdateRecordService for CRUD operations.

Constructor Summary

Constructors

Constructor	Description
IncrementalDataFeedEntityUpdateManager(DataFeedProcessService<DataFeedProcess> processService, IncrementalDataFeedEntityUpdateRecordService<IncrementalDataFeedEntityUpdateRecord> entityUpdateRecordService, com.broadleafcommerce.common.extension.TypeFactory typeFactory)

Method Summary

Modifier and Type	Method	Description
protected com.broadleafcommerce.data.tracking.core.context.ContextInfo	buildContextInfo(String tenantId, com.broadleafcommerce.data.tracking.core.type.OperationType operationType)
protected IncrementalDataFeedEntityUpdateRecord	buildRecord(IncrementalDataFeedEntityUpdateEvent event, DataFeedProcess process, Instant eventReceivedTime)
protected void	createIncrementalRecordsForEvent(IncrementalDataFeedEntityUpdateEvent event, List<DataFeedProcess> interestedProcesses)
protected IncrementalDataFeedEntityUpdateRecordService<IncrementalDataFeedEntityUpdateRecord>	getEntityUpdateRecordService()
protected DataFeedProcessService<DataFeedProcess>	getProcessService()
protected com.broadleafcommerce.common.extension.TypeFactory	getTypeFactory()
void	handle(IncrementalDataFeedEntityUpdateEvent event)	Handles a newly received IncrementalDataFeedEntityUpdateEvent to produce the appropriate IncrementalDataFeedEntityUpdateRecords for it.

Methods inherited from class java.lang.Object

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

Constructor Details

IncrementalDataFeedEntityUpdateManager

public IncrementalDataFeedEntityUpdateManager(DataFeedProcessService<DataFeedProcess> processService,
 IncrementalDataFeedEntityUpdateRecordService<IncrementalDataFeedEntityUpdateRecord> entityUpdateRecordService,
 com.broadleafcommerce.common.extension.TypeFactory typeFactory)

Method Details

handle

public void handle(IncrementalDataFeedEntityUpdateEvent event)

Handles a newly received IncrementalDataFeedEntityUpdateEvent to produce the appropriate IncrementalDataFeedEntityUpdateRecords for it.

Parameters:

event - the received IncrementalDataFeedEntityUpdateEvent

buildContextInfo

protected com.broadleafcommerce.data.tracking.core.context.ContextInfo buildContextInfo(String tenantId,
 com.broadleafcommerce.data.tracking.core.type.OperationType operationType)

createIncrementalRecordsForEvent

protected void createIncrementalRecordsForEvent(IncrementalDataFeedEntityUpdateEvent event,
 List<DataFeedProcess> interestedProcesses)

buildRecord

protected IncrementalDataFeedEntityUpdateRecord buildRecord(IncrementalDataFeedEntityUpdateEvent event,
 DataFeedProcess process,
 Instant eventReceivedTime)

getProcessService

protected DataFeedProcessService<DataFeedProcess> getProcessService()

getEntityUpdateRecordService

protected IncrementalDataFeedEntityUpdateRecordService<IncrementalDataFeedEntityUpdateRecord> getEntityUpdateRecordService()

getTypeFactory

protected com.broadleafcommerce.common.extension.TypeFactory getTypeFactory()