Package com.broadleafcommerce.datafeed.repository

Interface CustomizedDataFeedProcessExecutionRepository<D extends com.broadleafcommerce.data.tracking.core.Trackable>

All Known Subinterfaces:

DataFeedProcessExecutionRepository<D>, JpaDataFeedProcessExecutionRepository<D>

All Known Implementing Classes:

JpaCustomizedDataFeedProcessExecutionRepository

public interface CustomizedDataFeedProcessExecutionRepository<D extends com.broadleafcommerce.data.tracking.core.Trackable>

Advanced repository methods for DataFeedProcessExecutionRepository.

Method Summary

Modifier and Type	Method	Description
D	initializeNotificationState(String id, String messageType, com.broadleafcommerce.data.tracking.core.context.ContextInfo contextInfo)	Atomically finds the DataFeedProcessExecution for the given id, and initializes its NotificationState for messageType.
D	setQueriedDataFileLocation(String id, String queriedDataFileLocation, String whereCurrentStatus, com.broadleafcommerce.data.tracking.core.context.ContextInfo contextInfo)	Atomically sets DataFeedProcessExecution.getQueriedDataFileLocation() on the specified execution.
D	setStatus(String id, String newStatus, String whereCurrentStatus, com.broadleafcommerce.data.tracking.core.context.ContextInfo contextInfo)	Atomically sets a new DataFeedProcessExecution.getStatus() on the specified execution.
D	setStatusAndCompletionDetails(String id, String newStatus, Instant endTime, boolean containsErrors, List<String> errorDetails, String whereCurrentStatus, com.broadleafcommerce.data.tracking.core.context.ContextInfo contextInfo)	Atomically sets a new DataFeedProcessExecution.getStatus() and completion details on the specified execution.
D	setStatusAndStartTime(String id, String newStatus, Instant startTime, String whereCurrentStatus, com.broadleafcommerce.data.tracking.core.context.ContextInfo contextInfo)	Atomically sets a new DataFeedProcessExecution.getStatus() and DataFeedProcessExecution.getStartTime() on the specified execution.

Method Details

initializeNotificationState

@Nullable
@Policy(operationTypes=UPDATE)
D initializeNotificationState(String id,
 String messageType,
 @Nullable
 com.broadleafcommerce.data.tracking.core.context.ContextInfo contextInfo)

Atomically finds the DataFeedProcessExecution for the given id, and initializes its NotificationState for messageType.

Parameters:

id - the DataFeedProcessExecution.getId() for which to initialize the notification state

messageType - the message type (ex: NotificationState.getName()

contextInfo - context information around multitenant state

Returns:

the updated DataFeedProcessExecution if successfully found and updated, null otherwise

setStatus

@Nullable
@Policy(operationTypes=UPDATE)
D setStatus(String id,
 String newStatus,
 @Nullable
 String whereCurrentStatus,
 @Nullable
 com.broadleafcommerce.data.tracking.core.context.ContextInfo contextInfo)

Atomically sets a new DataFeedProcessExecution.getStatus() on the specified execution.

Parameters:

id - the ID of the execution to update

newStatus - the new value to set for DataFeedProcessExecution.getStatus()

whereCurrentStatus - (optional) if provided, the update will only be applied if the execution currently has this value for its DataFeedProcessExecution.getStatus()

contextInfo - context information around multitenant state

Returns:

the updated execution if successfully updated, else null

setStatusAndStartTime

@Nullable
@Policy(operationTypes=UPDATE)
D setStatusAndStartTime(String id,
 String newStatus,
 Instant startTime,
 @Nullable
 String whereCurrentStatus,
 @Nullable
 com.broadleafcommerce.data.tracking.core.context.ContextInfo contextInfo)

Atomically sets a new DataFeedProcessExecution.getStatus() and DataFeedProcessExecution.getStartTime() on the specified execution.

Parameters:

id - the ID of the execution to update

newStatus - the new value to set for DataFeedProcessExecution.getStatus()

startTime - the value to set for DataFeedProcessExecution.getStartTime()

whereCurrentStatus - (optional) if provided, the update will only be applied if the execution currently has this value for its DataFeedProcessExecution.getStatus()

contextInfo - context information around multitenant state

Returns:

the updated execution if successfully updated, else null

setStatusAndCompletionDetails

@Nullable
@Policy(operationTypes=UPDATE)
D setStatusAndCompletionDetails(String id,
 String newStatus,
 Instant endTime,
 boolean containsErrors,
 @Nullable
 List<String> errorDetails,
 @Nullable
 String whereCurrentStatus,
 @Nullable
 com.broadleafcommerce.data.tracking.core.context.ContextInfo contextInfo)

Atomically sets a new DataFeedProcessExecution.getStatus() and completion details on the specified execution.

Parameters:

id - the ID of the execution to update

newStatus - the new value to set for DataFeedProcessExecution.getStatus()

endTime - the value to set for DataFeedProcessExecution.getEndTime()

containsErrors - the value to set for DataFeedProcessExecution.isContainsErrors()

errorDetails - (optional) the value to set for DataFeedProcessExecution.getErrorDetails()

whereCurrentStatus - (optional) if provided, the update will only be applied if the execution currently has this value for its DataFeedProcessExecution.getStatus()

contextInfo - context information around multitenant state

Returns:

the updated execution if successfully updated, else null

setQueriedDataFileLocation

@Nullable
@Policy(operationTypes=UPDATE)
D setQueriedDataFileLocation(String id,
 String queriedDataFileLocation,
 @Nullable
 String whereCurrentStatus,
 @Nullable
 com.broadleafcommerce.data.tracking.core.context.ContextInfo contextInfo)

Atomically sets DataFeedProcessExecution.getQueriedDataFileLocation() on the specified execution.

Parameters:

id - the ID of the execution to update

queriedDataFileLocation - the value to set for DataFeedProcessExecution.getQueriedDataFileLocation()

whereCurrentStatus - (optional) if provided, the update will only be applied if the execution currently has this value for its DataFeedProcessExecution.getStatus()

contextInfo - context information around multitenant state

Returns:

the updated execution if successfully updated, else null