de.hybris.platform.processing.distributed.defaultimpl

Class DistributedProcessHelper

java.lang.Object

de.hybris.platform.processing.distributed.defaultimpl.DistributedProcessHelper

public final class DistributedProcessHelper
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	DistributedProcessHelper.FlushInBatchesContext

Constructor Summary

Constructors

Constructor and Description
DistributedProcessHelper()

Method Summary

Modifier and Type	Method and Description
static <T> T	doInTransaction(Supplier<T> action)
static <T> T	doInTxWithOptimisticLocking(Supplier<T> action)
static <T> T	doWithOptimisticLocking(Supplier<T> action)
static DistributedProcessModel	executeWithDisabledUniquenessCheck(DistributedProcessHandler handler, Supplier<DistributedProcessModel> action)
static DistributedProcessHelper.FlushInBatchesContext	flushInBatches(ModelService modelService, int flushSize)
static DistributedProcessHandler	getHandler(ApplicationContext applicationContext, String handlerBeanId)
static boolean	isCreated(DistributedProcessModel process)
static boolean	isFinished(DistributedProcessModel process)
static DistributedProcessModel	postProcess(DistributedProcessHandler handler, Supplier<DistributedProcessModel> action)
static void	requireProcessToBeInState(DistributedProcessModel process, DistributedProcessState state)
static Function<Supplier<DistributedProcessModel>,DistributedProcessModel>	runInEnvironment(DistributedProcessHandler handler, de.hybris.platform.processing.distributed.defaultimpl.DistributedProcessHelper.EnvFeature... features)

Methods inherited from class java.lang.Object

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

Constructor Detail

DistributedProcessHelper

public DistributedProcessHelper()

Method Detail

doInTxWithOptimisticLocking

public static <T> T doInTxWithOptimisticLocking(Supplier<T> action)

doInTransaction

public static <T> T doInTransaction(Supplier<T> action)

doWithOptimisticLocking

public static <T> T doWithOptimisticLocking(Supplier<T> action)

isCreated

public static boolean isCreated(DistributedProcessModel process)

isFinished

public static boolean isFinished(DistributedProcessModel process)

flushInBatches

public static DistributedProcessHelper.FlushInBatchesContext flushInBatches(ModelService modelService,
                                                                            int flushSize)

getHandler

public static DistributedProcessHandler getHandler(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)