Package com.broadleafcommerce.datafeed.provider.jpa.repository.trackable

Class JpaCustomizedDataFeedProcessExecutionRepository<D extends JpaDataFeedProcessExecution>

java.lang.Object

com.broadleafcommerce.datafeed.provider.jpa.repository.trackable.JpaCustomizedDataFeedProcessExecutionRepository<D>

Type Parameters:

D - the persisted domain type

All Implemented Interfaces:

CustomizedDataFeedProcessExecutionRepository<D>, org.springframework.beans.factory.InitializingBean

public class JpaCustomizedDataFeedProcessExecutionRepository<D extends JpaDataFeedProcessExecution>
extends Object
implements CustomizedDataFeedProcessExecutionRepository<D>, org.springframework.beans.factory.InitializingBean

JPA implementation of CustomizedDataFeedProcessExecutionRepository.

Constructor Summary

Constructors

Constructor	Description
JpaCustomizedDataFeedProcessExecutionRepository(com.broadleafcommerce.data.tracking.core.TrackableBehaviorUtil behaviorUtil, com.broadleafcommerce.data.tracking.jpa.filtering.fetch.rsql.JpaFiltersCriteriaBuilder criteriaBuilder, com.broadleafcommerce.common.jpa.RepositoryEntityTypeManager repositoryEntityTypeManager, JpaDataFeedQueryHelper queryHelper)

Method Summary

Modifier and Type	Method	Description
void	afterPropertiesSet()
protected DataFeedProcessExecutionRepository<D>	getBaseRepository()	Lazy injection so we can access base repository methods.
protected com.broadleafcommerce.data.tracking.core.TrackableBehaviorUtil	getBehaviorUtil()
protected com.broadleafcommerce.data.tracking.jpa.filtering.fetch.rsql.JpaFiltersCriteriaBuilder	getCriteriaBuilder()
protected jakarta.persistence.EntityManager	getEntityManager()
protected com.broadleafcommerce.data.tracking.jpa.filtering.narrow.JpaNarrowingHelper	getNarrowingHelper()
protected com.broadleafcommerce.common.messaging.notification.NotificationStateService	getNotificationStateService()	Lazy injection since this is technically a service component.
protected JpaDataFeedQueryHelper	getQueryHelper()
protected com.broadleafcommerce.common.jpa.RepositoryEntityTypeManager	getRepositoryEntityTypeManager()
protected com.broadleafcommerce.common.messaging.notification.domain.NotificationState	initializeAndResetNotificationState(D entity, String notificationStateName, Instant changeTimestamp)
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.
void	setBaseRepository(DataFeedProcessExecutionRepository<D> baseRepository)	Lazy injection so we can access base repository methods.
void	setNotificationStateService(com.broadleafcommerce.common.messaging.notification.NotificationStateService notificationStateService)	Lazy injection since this is technically a service component.
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.

Methods inherited from class java.lang.Object

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

Constructor Details

JpaCustomizedDataFeedProcessExecutionRepository

public JpaCustomizedDataFeedProcessExecutionRepository(com.broadleafcommerce.data.tracking.core.TrackableBehaviorUtil behaviorUtil,
 com.broadleafcommerce.data.tracking.jpa.filtering.fetch.rsql.JpaFiltersCriteriaBuilder criteriaBuilder,
 com.broadleafcommerce.common.jpa.RepositoryEntityTypeManager repositoryEntityTypeManager,
 JpaDataFeedQueryHelper queryHelper)

Method Details

afterPropertiesSet

public void afterPropertiesSet()
                        throws Exception

Specified by:

afterPropertiesSet in interface org.springframework.beans.factory.InitializingBean

Throws:

Exception

initializeNotificationState

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

Description copied from interface: CustomizedDataFeedProcessExecutionRepository

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

Specified by:

initializeNotificationState in interface CustomizedDataFeedProcessExecutionRepository<D extends JpaDataFeedProcessExecution>

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

initializeAndResetNotificationState

protected com.broadleafcommerce.common.messaging.notification.domain.NotificationState initializeAndResetNotificationState(D entity,
 String notificationStateName,
 Instant changeTimestamp)

setStatus

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

Description copied from interface: CustomizedDataFeedProcessExecutionRepository

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

Specified by:

setStatus in interface CustomizedDataFeedProcessExecutionRepository<D extends JpaDataFeedProcessExecution>

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)
@Transactional("datafeedTransactionManager")
public D setStatusAndStartTime(String id,
 String newStatus,
 Instant startTime,
 @Nullable
 String whereCurrentStatus,
 @Nullable
 com.broadleafcommerce.data.tracking.core.context.ContextInfo contextInfo)

Description copied from interface: CustomizedDataFeedProcessExecutionRepository

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

Specified by:

setStatusAndStartTime in interface CustomizedDataFeedProcessExecutionRepository<D extends JpaDataFeedProcessExecution>

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)
@Transactional("datafeedTransactionManager")
public 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)

Description copied from interface: CustomizedDataFeedProcessExecutionRepository

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

Specified by:

setStatusAndCompletionDetails in interface CustomizedDataFeedProcessExecutionRepository<D extends JpaDataFeedProcessExecution>

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)
@Transactional("datafeedTransactionManager")
public D setQueriedDataFileLocation(String id,
 String queriedDataFileLocation,
 @Nullable
 String whereCurrentStatus,
 @Nullable
 com.broadleafcommerce.data.tracking.core.context.ContextInfo contextInfo)

Description copied from interface: CustomizedDataFeedProcessExecutionRepository

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

Specified by:

setQueriedDataFileLocation in interface CustomizedDataFeedProcessExecutionRepository<D extends JpaDataFeedProcessExecution>

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

getBehaviorUtil

protected com.broadleafcommerce.data.tracking.core.TrackableBehaviorUtil getBehaviorUtil()

getCriteriaBuilder

protected com.broadleafcommerce.data.tracking.jpa.filtering.fetch.rsql.JpaFiltersCriteriaBuilder getCriteriaBuilder()

getRepositoryEntityTypeManager

protected com.broadleafcommerce.common.jpa.RepositoryEntityTypeManager getRepositoryEntityTypeManager()

getQueryHelper

protected JpaDataFeedQueryHelper getQueryHelper()

getEntityManager

protected jakarta.persistence.EntityManager getEntityManager()

getNarrowingHelper

protected com.broadleafcommerce.data.tracking.jpa.filtering.narrow.JpaNarrowingHelper getNarrowingHelper()

getBaseRepository

protected DataFeedProcessExecutionRepository<D> getBaseRepository()

Lazy injection so we can access base repository methods.

setBaseRepository

@Autowired
@Lazy
public void setBaseRepository(DataFeedProcessExecutionRepository<D> baseRepository)

Lazy injection so we can access base repository methods.

getNotificationStateService

protected com.broadleafcommerce.common.messaging.notification.NotificationStateService getNotificationStateService()

Lazy injection since this is technically a service component.

setNotificationStateService

@Autowired
@Lazy
public void setNotificationStateService(com.broadleafcommerce.common.messaging.notification.NotificationStateService notificationStateService)

Lazy injection since this is technically a service component.