Package com.broadleafcommerce.workflow.provider.jpa.repository

Class JpaCustomizedSideEffectRepository<D extends JpaSideEffect,E extends JpaWorkflow>

java.lang.Object

com.broadleafcommerce.workflow.provider.jpa.repository.JpaCustomizedSideEffectRepository<D,E>

Type Parameters:

D - The possibly extended type of JpaSideEffect

E - The possibly extended type of JpaWorkflow

All Implemented Interfaces:

com.broadleafcommerce.orchestration.internal.SideEffectHandler, CustomizedSideEffectRepository<D>

public class JpaCustomizedSideEffectRepository<D extends JpaSideEffect,E extends JpaWorkflow>
extends Object
implements CustomizedSideEffectRepository<D>, com.broadleafcommerce.orchestration.internal.SideEffectHandler

See CustomizedSideEffectRepository and SideEffectHandler.

Constructor Summary

Constructors

Constructor	Description
JpaCustomizedSideEffectRepository(com.fasterxml.jackson.databind.ObjectMapper objectMapper, com.broadleafcommerce.common.extension.TypeFactory typeFactory, ExecutionProperties executionProperties, com.broadleafcommerce.data.tracking.core.BasicAuditUtility auditUtility)

Method Summary

Modifier and Type	Method	Description
void	activityBoundary(String name, boolean isEnd)
void	activityBoundary(String name, Duration duration, boolean isEnd)
protected D	addItem(String workflowId, String tenantId, Object object, Class<?> resultClass)
<R> R	addSideEffect(Class<?> resultClass, com.broadleafcommerce.orchestration.workflow.Functions.Func<R> func, Object activity)
D	addSignal(String workflowId, com.broadleafcommerce.data.tracking.core.context.ContextInfo contextInfo, Method signalMethod, Object... args)	Add a Signal as a side effect.
void	applyRecent()
void	flush()
void	setRepository(JpaSideEffectRepository<D> repository)
void	setWorkflowRepository(JpaWorkflowRepository<E> workflowRepository)

Methods inherited from class java.lang.Object

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

Constructor Details

JpaCustomizedSideEffectRepository

public JpaCustomizedSideEffectRepository(com.fasterxml.jackson.databind.ObjectMapper objectMapper,
 com.broadleafcommerce.common.extension.TypeFactory typeFactory,
 ExecutionProperties executionProperties,
 com.broadleafcommerce.data.tracking.core.BasicAuditUtility auditUtility)

Method Details

activityBoundary

@Policy(operationTypes=UPDATE)
public void activityBoundary(String name,
 boolean isEnd)

Specified by:

activityBoundary in interface com.broadleafcommerce.orchestration.internal.SideEffectHandler

activityBoundary

@Policy(operationTypes=UPDATE)
public void activityBoundary(String name,
 Duration duration,
 boolean isEnd)

Specified by:

activityBoundary in interface com.broadleafcommerce.orchestration.internal.SideEffectHandler

addSideEffect

@Policy(operationTypes=UPDATE)
public <R> R addSideEffect(Class<?> resultClass,
 com.broadleafcommerce.orchestration.workflow.Functions.Func<R> func,
 @Nullable
 Object activity)

Specified by:

addSideEffect in interface com.broadleafcommerce.orchestration.internal.SideEffectHandler

applyRecent

@Policy(operationTypes=UPDATE)
public void applyRecent()

Specified by:

applyRecent in interface com.broadleafcommerce.orchestration.internal.SideEffectHandler

flush

@Policy(operationTypes=UPDATE)
public void flush()

Specified by:

flush in interface com.broadleafcommerce.orchestration.internal.SideEffectHandler

addSignal

@Policy(operationTypes=UPDATE)
public D addSignal(String workflowId,
 @Nullable
 com.broadleafcommerce.data.tracking.core.context.ContextInfo contextInfo,
 Method signalMethod,
 Object... args)

Description copied from interface: CustomizedSideEffectRepository

Add a Signal as a side effect.

Specified by:

addSignal in interface CustomizedSideEffectRepository<D extends JpaSideEffect>

Parameters:

workflowId - The primary key for the workflow execution

contextInfo - Data Tracking context information

signalMethod - The method name to call on SimpleWorkflow

args - The method arguments

Returns:

The resulting, persisted side effect

addItem

@NotNull
protected D addItem(String workflowId,
 @Nullable
 String tenantId,
 Object object,
 Class<?> resultClass)

setRepository

@Autowired
@Lazy
public void setRepository(JpaSideEffectRepository<D> repository)

setWorkflowRepository

@Autowired
@Lazy
public void setWorkflowRepository(JpaWorkflowRepository<E> workflowRepository)