Class TasksQueueGatewayTest

All Implemented Interfaces:
JaloSessionHolder

@IntegrationTest public class TasksQueueGatewayTest extends BaseGatewayTest
  • Constructor Details

    • TasksQueueGatewayTest

      public TasksQueueGatewayTest()
  • Method Details

    • setUp

      public void setUp() throws Exception
      Throws:
      Exception
    • tearDown

      public void tearDown() throws Exception
      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()