Class DefaultTaskServiceNodeGroupsIntegrationTest

    • Field Detail

      • metricRegistry

        protected com.codahale.metrics.MetricRegistry metricRegistry
      • taskEngineRetryTemplate

        protected org.springframework.retry.support.RetryTemplate taskEngineRetryTemplate
    • Constructor Detail

      • DefaultTaskServiceNodeGroupsIntegrationTest

        public DefaultTaskServiceNodeGroupsIntegrationTest()
    • Method Detail

      • setUp

        public void setUp()
      • tearDown

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

        protected abstract TasksProvider getTasksProvider()