Class TasksQueueGatewayTest

    • Constructor Detail

      • TasksQueueGatewayTest

        public TasksQueueGatewayTest()
    • Method Detail

      • setUp

        public void setUp()
                   throws java.lang.Exception
        Throws:
        java.lang.Exception
      • tearDown

        public void tearDown()
                      throws java.lang.Exception
        Throws:
        java.lang.Exception
      • shouldExecuteGetTasksForWorkerAndMarkForProcessingQuery

        public void shouldExecuteGetTasksForWorkerAndMarkForProcessingQuery()
      • shouldExecuteGetTasksForWorkerAndMarkForProcessingQueryExclusiveMode

        public void shouldExecuteGetTasksForWorkerAndMarkForProcessingQueryExclusiveMode()
      • shouldFillNullNodeIdAndNodeGroupWhenAddingTasksToQueue

        public void shouldFillNullNodeIdAndNodeGroupWhenAddingTasksToQueue()
      • shouldExecuteCleanQuery

        public void shouldExecuteCleanQuery()
      • shouldExecuteAddTasksQuery

        public void shouldExecuteAddTasksQuery()
      • 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()