Class DefaultTaskServiceNodeGroupsIntegrationTest

    • Constructor Detail

      • DefaultTaskServiceNodeGroupsIntegrationTest

        public DefaultTaskServiceNodeGroupsIntegrationTest()
    • Method Detail

      • shouldExecuteOnlyTasksForOwnNodeGroup

        public void shouldExecuteOnlyTasksForOwnNodeGroup()
                                                   throws java.lang.Exception
        Throws:
        java.lang.Exception
      • shouldExecuteOnlyTasksForOwnNodeGroupInExclusiveMode

        public void shouldExecuteOnlyTasksForOwnNodeGroupInExclusiveMode()
                                                                  throws java.lang.Exception
        Throws:
        java.lang.Exception
      • shouldFailAllExpiredTasks

        public void shouldFailAllExpiredTasks()
                                       throws java.lang.Exception
        Throws:
        java.lang.Exception
      • shouldFailOnlyExpiredTasksForOwnNodeGroupInExclusiveMode

        public void shouldFailOnlyExpiredTasksForOwnNodeGroupInExclusiveMode()
                                                                      throws java.lang.Exception
        Throws:
        java.lang.Exception
      • shouldExecuteOnlyTasksForOwnNode

        public void shouldExecuteOnlyTasksForOwnNode()
                                              throws java.lang.Exception
        Throws:
        java.lang.Exception
      • shouldFailOnlyExpiredTasksForOwnNodeIdInExclusiveMode

        public void shouldFailOnlyExpiredTasksForOwnNodeIdInExclusiveMode()
                                                                   throws java.lang.Exception
        Throws:
        java.lang.Exception
      • shouldExecuteOnlyTasksForOwnNodeWhenNoGroupDefined

        public void shouldExecuteOnlyTasksForOwnNodeWhenNoGroupDefined()
                                                                throws java.lang.Exception
        Throws:
        java.lang.Exception
      • shouldExecuteOnlyTasksForOwnNodeInExclusiveMode

        public void shouldExecuteOnlyTasksForOwnNodeInExclusiveMode()
                                                             throws java.lang.Exception
        Throws:
        java.lang.Exception
      • shouldExecuteTasksWithConflictingNodeIfAndNodeGroupAssignment

        public void shouldExecuteTasksWithConflictingNodeIfAndNodeGroupAssignment()
                                                                           throws java.lang.Exception
        Throws:
        java.lang.Exception
      • shouldExecuteTaskWithoutSpecifiedNodeGroupByAnyNode

        public void shouldExecuteTaskWithoutSpecifiedNodeGroupByAnyNode()
                                                                 throws java.lang.Exception
        Throws:
        java.lang.Exception
      • createTriggerTasks

        protected java.util.List<java.lang.Long> createTriggerTasks​(int count)
      • shouldNotProcessTriggerTasksWhenItIsDisabledByConfiguration

        public void shouldNotProcessTriggerTasksWhenItIsDisabledByConfiguration()
                                                                         throws java.lang.Exception
        Throws:
        java.lang.Exception