Package de.hybris.platform.task.impl

Class DefaultTaskServiceBaseTest

java.lang.Object

de.hybris.platform.testframework.HybrisJUnit4Test

de.hybris.platform.servicelayer.ServicelayerBaseTest

de.hybris.platform.task.impl.DefaultTaskServiceBaseTest

All Implemented Interfaces:

JaloSessionHolder

Direct Known Subclasses:

DefaultTaskServiceNodeGroupsIntegrationTest, DefaultTaskServiceRepollTest

public abstract class DefaultTaskServiceBaseTest
extends ServicelayerBaseTest

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	DefaultTaskServiceBaseTest.TestTaskService

Field Summary

Fields

Modifier and Type	Field	Description
protected FlexibleSearchService	flexibleSearchService
protected com.codahale.metrics.MetricRegistry	metricRegistry
protected ModelService	modelService
protected org.springframework.retry.support.RetryTemplate	taskEngineRetryTemplate
protected java.util.Set<PK>	tasksCreated
protected TaskService	taskService
protected TypeService	typeService

Fields inherited from class de.hybris.platform.testframework.HybrisJUnit4Test

jaloSession

Constructor Summary

Constructors

Constructor	Description
DefaultTaskServiceBaseTest()

Method Summary

Modifier and Type	Method	Description
protected void	assureTaskEngineStopped()
protected java.lang.Long	createExpiredTask(int nodeId)
protected java.lang.Long	createExpiredTask(int nodeId, java.util.function.UnaryOperator<TaskModel> extend)
protected java.lang.Long	createExpiredTask(java.lang.String group)
protected java.lang.Long	createExpiredTask(java.lang.String group, java.util.function.UnaryOperator<TaskModel> extend)
protected java.lang.Long	createTask()
protected java.lang.Long	createTask(int nodeId)
protected java.lang.Long	createTask(int nodeId, java.lang.String group)
protected java.lang.Long	createTask(int nodeId, java.lang.String group, java.util.function.UnaryOperator<TaskModel> extend)
protected java.lang.Long	createTask(int nodeId, java.util.function.UnaryOperator<TaskModel> extend)
protected java.lang.Long	createTask(java.lang.String group)
protected java.lang.Long	createTask(java.lang.String group, java.util.function.UnaryOperator<TaskModel> extend)
protected void	enableExclusiveMode()
protected abstract TasksProvider	getTasksProvider()
protected void	markTaskForRemovalAfterTest(PK pk)
protected void	resetExclusiveMode()
void	setUp()
void	tearDown()

Methods inherited from class de.hybris.platform.servicelayer.ServicelayerBaseTest

autowireProperties, getApplicationContext, getBeanName, prepareApplicationContextAndSession

Methods inherited from class de.hybris.platform.testframework.HybrisJUnit4Test

establishJaloSession, finish, getOrCreateCurrency, getOrCreateLanguage, init, intenseChecksActivated, takeJaloSession

Methods inherited from class java.lang.Object

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

Field Detail

tasksCreated

protected final java.util.Set<PK> tasksCreated

modelService

protected ModelService modelService

flexibleSearchService

protected FlexibleSearchService flexibleSearchService

taskService

protected TaskService taskService

typeService

protected TypeService typeService

metricRegistry

protected com.codahale.metrics.MetricRegistry metricRegistry

taskEngineRetryTemplate

protected org.springframework.retry.support.RetryTemplate taskEngineRetryTemplate

Constructor Detail

DefaultTaskServiceBaseTest

public DefaultTaskServiceBaseTest()

Method Detail

setUp

public void setUp()

tearDown

public void tearDown()

markTaskForRemovalAfterTest

protected void markTaskForRemovalAfterTest(PK pk)

createTask

protected java.lang.Long createTask(java.lang.String group,
                                    java.util.function.UnaryOperator<TaskModel> extend)

createExpiredTask

protected java.lang.Long createExpiredTask(java.lang.String group,
                                           java.util.function.UnaryOperator<TaskModel> extend)

createTask

protected java.lang.Long createTask(int nodeId,
                                    java.util.function.UnaryOperator<TaskModel> extend)

createExpiredTask

protected java.lang.Long createExpiredTask(int nodeId,
                                           java.util.function.UnaryOperator<TaskModel> extend)

createTask

protected java.lang.Long createTask(int nodeId,
                                    java.lang.String group,
                                    java.util.function.UnaryOperator<TaskModel> extend)

createTask

protected java.lang.Long createTask()

createTask

protected java.lang.Long createTask(java.lang.String group)

createExpiredTask

protected java.lang.Long createExpiredTask(java.lang.String group)

createTask

protected java.lang.Long createTask(int nodeId)

createExpiredTask

protected java.lang.Long createExpiredTask(int nodeId)

createTask

protected java.lang.Long createTask(int nodeId,
                                    java.lang.String group)

getTasksProvider

protected abstract TasksProvider getTasksProvider()

assureTaskEngineStopped

protected void assureTaskEngineStopped()
                                throws java.util.concurrent.TimeoutException

Throws:

java.util.concurrent.TimeoutException

enableExclusiveMode

protected void enableExclusiveMode()

resetExclusiveMode

protected void resetExclusiveMode()