Class DistributedProcessHelper
java.lang.Object
de.hybris.platform.processing.distributed.defaultimpl.DistributedProcessHelper
-
Nested Class Summary
Nested Classes -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionstatic <T> TdoInTransaction(Supplier<T> action) static <T> TdoInTxWithOptimisticLocking(Supplier<T> action) static <T> TdoWithOptimisticLocking(Supplier<T> action) static DistributedProcessModelexecuteWithDisabledUniquenessCheck(DistributedProcessHandler handler, Supplier<DistributedProcessModel> action) flushInBatches(ModelService modelService, int flushSize) static DistributedProcessHandlergetHandler(org.springframework.context.ApplicationContext applicationContext, String handlerBeanId) static booleanisCreated(DistributedProcessModel process) static booleanisFinished(DistributedProcessModel process) static DistributedProcessModelpostProcess(DistributedProcessHandler handler, Supplier<DistributedProcessModel> action) static voidrequireProcessToBeInState(DistributedProcessModel process, DistributedProcessState state) runInEnvironment(DistributedProcessHandler handler, de.hybris.platform.processing.distributed.defaultimpl.DistributedProcessHelper.EnvFeature... features)
-
Constructor Details
-
DistributedProcessHelper
public DistributedProcessHelper()
-
-
Method Details
-
doInTxWithOptimisticLocking
-
doInTransaction
-
doWithOptimisticLocking
-
isCreated
-
isFinished
-
flushInBatches
public static DistributedProcessHelper.FlushInBatchesContext flushInBatches(ModelService modelService, int flushSize) -
getHandler
public static DistributedProcessHandler getHandler(org.springframework.context.ApplicationContext applicationContext, String handlerBeanId) -
requireProcessToBeInState
public static void requireProcessToBeInState(DistributedProcessModel process, DistributedProcessState state) -
runInEnvironment
public static Function<Supplier<DistributedProcessModel>,DistributedProcessModel> runInEnvironment(DistributedProcessHandler handler, de.hybris.platform.processing.distributed.defaultimpl.DistributedProcessHelper.EnvFeature... features) -
executeWithDisabledUniquenessCheck
public static DistributedProcessModel executeWithDisabledUniquenessCheck(DistributedProcessHandler handler, Supplier<DistributedProcessModel> action) -
postProcess
public static DistributedProcessModel postProcess(DistributedProcessHandler handler, Supplier<DistributedProcessModel> action)
-