Class TasksQueueGatewayTest
java.lang.Object
de.hybris.platform.testframework.HybrisJUnit4Test
de.hybris.platform.servicelayer.ServicelayerBaseTest
de.hybris.platform.task.impl.gateways.BaseGatewayTest
de.hybris.platform.task.impl.gateways.TasksQueueGatewayTest
- All Implemented Interfaces:
JaloSessionHolder
-
Field Summary
Fields inherited from class de.hybris.platform.task.impl.gateways.BaseGatewayTest
jdbcTemplate, taskService, testHelperFields inherited from class de.hybris.platform.testframework.HybrisJUnit4Test
jaloSession -
Constructor Summary
Constructors -
Method Summary
Methods inherited from class de.hybris.platform.task.impl.gateways.BaseGatewayTest
assertTableExists, assertTableNotExists, cleanUpTable, disableTaskEngine, enableTaskEngine, prepareTable, setupBaseGatewayTestMethods inherited from class de.hybris.platform.servicelayer.ServicelayerBaseTest
autowireProperties, getApplicationContext, getBeanName, prepareApplicationContextAndSessionMethods inherited from class de.hybris.platform.testframework.HybrisJUnit4Test
establishJaloSession, finish, getOrCreateCurrency, getOrCreateLanguage, init, intenseChecksActivated, takeJaloSession
-
Constructor Details
-
TasksQueueGatewayTest
public TasksQueueGatewayTest()
-
-
Method Details
-
setUp
- Throws:
Exception
-
tearDown
- Throws:
Exception
-
shouldExecuteGetTasksForWorkerAndMarkForProcessingQuery
public void shouldExecuteGetTasksForWorkerAndMarkForProcessingQuery() -
shouldExecuteGetTasksForWorkerAndMarkForProcessingQueryExclusiveMode
public void shouldExecuteGetTasksForWorkerAndMarkForProcessingQueryExclusiveMode() -
shouldFillNullNodeIdAndNodeGroupWhenAddingTasksToQueue
public void shouldFillNullNodeIdAndNodeGroupWhenAddingTasksToQueue() -
shouldExecuteCleanQuery
public void shouldExecuteCleanQuery() -
shouldExecuteCleanQueryWithLargeInterval
public void shouldExecuteCleanQueryWithLargeInterval() -
shouldExecuteAddTasksQuery
public void shouldExecuteAddTasksQuery() -
shouldCloseTransactionInAddTasksWhenErrorThrown
public void shouldCloseTransactionInAddTasksWhenErrorThrown() -
shouldRandomlySetRangeWhenExecutingAddTasksQuery
public void shouldRandomlySetRangeWhenExecutingAddTasksQuery() -
shouldExecuteGetTasksCountQuery
public void shouldExecuteGetTasksCountQuery() -
shouldExecuteGetConditionsToScheduleQuery
public void shouldExecuteGetConditionsToScheduleQuery() -
shouldExecuteDeleteTasksQuery
public void shouldExecuteDeleteTasksQuery() -
shouldExecuteUnlockTasksForWorkersQuery
public void shouldExecuteUnlockTasksForWorkersQuery() -
shouldExecuteDropTable
public void shouldExecuteDropTable() -
shouldReturnTrueIfTableExists
public void shouldReturnTrueIfTableExists() -
shouldReturnFalseIfTableDoesNotExist
public void shouldReturnFalseIfTableDoesNotExist() -
shouldThrowExceptionWhenRetriesOfGettingTasksAreNotEnough
public void shouldThrowExceptionWhenRetriesOfGettingTasksAreNotEnough() -
shouldThrowExceptionWhenRetriesAreDisabled
public void shouldThrowExceptionWhenRetriesAreDisabled() -
shouldThrowExceptionWhenRetriesAreNegative
public void shouldThrowExceptionWhenRetriesAreNegative() -
shouldReturnTasksAfterRetryInCaseOfDeadlock
public void shouldReturnTasksAfterRetryInCaseOfDeadlock() -
shouldReturnTasksAfterMultipleRetriesInCaseOfDeadlock
public void shouldReturnTasksAfterMultipleRetriesInCaseOfDeadlock() -
shouldReturnTasksIfnNoDeadlock
public void shouldReturnTasksIfnNoDeadlock()
-