Class AbortingCronJobsIntegrationTest

    • Constructor Detail

      • AbortingCronJobsIntegrationTest

        public AbortingCronJobsIntegrationTest()
    • 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
      • shouldAbortCronJobOnRunningOnGivenNode

        public void shouldAbortCronJobOnRunningOnGivenNode()
      • shouldAbortCronJobOnRunningRestartedOnGivenNode

        public void shouldAbortCronJobOnRunningRestartedOnGivenNode()
      • shouldAbortCronJobRunningOnlyOnStaleNodesWhenNoActiveNodeIdsIsProvided

        public void shouldAbortCronJobRunningOnlyOnStaleNodesWhenNoActiveNodeIdsIsProvided()
      • shouldAbortCronJobRunningOnNonExistingNode

        public void shouldAbortCronJobRunningOnNonExistingNode()
      • shouldAbortCronJobRunningOnNonExistingNodeWithoutStaleNodes

        public void shouldAbortCronJobRunningOnNonExistingNodeWithoutStaleNodes()
      • shouldNotAbortCronJobsInStatusesOtherThanRunning

        public void shouldNotAbortCronJobsInStatusesOtherThanRunning()
      • shouldNotAbortCronJobsInStatusesOtherThanRunningWhenUsingActiveNodeIds

        public void shouldNotAbortCronJobsInStatusesOtherThanRunningWhenUsingActiveNodeIds()
      • shouldNotAbortCronJobsInStatusesOtherThanRunningWhenUsingOnlyActiveNodeIds

        public void shouldNotAbortCronJobsInStatusesOtherThanRunningWhenUsingOnlyActiveNodeIds()
      • shouldAbortRunningCronJobsMarkedToBeChecked

        public void shouldAbortRunningCronJobsMarkedToBeChecked()
      • shouldAbortCronJobOnRunningRestartedMarkedToBeChecked

        public void shouldAbortCronJobOnRunningRestartedMarkedToBeChecked()
      • shouldCleanInvalidEntries

        public void shouldCleanInvalidEntries()
      • shouldCleanInvalidEntriesAndAbortValidOnes

        public void shouldCleanInvalidEntriesAndAbortValidOnes()
      • shouldAbortRunningCronJobsMarkedToBeCheckedWithCurrentRunningOnClusterNode

        public void shouldAbortRunningCronJobsMarkedToBeCheckedWithCurrentRunningOnClusterNode()
      • shouldAbortAllRunningCronJobsIfMaxCronJobsCountIsZero

        public void shouldAbortAllRunningCronJobsIfMaxCronJobsCountIsZero()
      • shouldNotAbortCronJobsInStatusesOtherThanRunningWhenAbortingLocalCronJobs

        public void shouldNotAbortCronJobsInStatusesOtherThanRunningWhenAbortingLocalCronJobs()
      • shouldAbortOnlyAsManyCronJobsAsDefinedInParameter

        public void shouldAbortOnlyAsManyCronJobsAsDefinedInParameter()
      • shouldPublishAbortAfterCrashEvent

        public void shouldPublishAbortAfterCrashEvent()
      • shouldPublishAbortAfterCrashEventForLocallyCheckedCronJobs

        public void shouldPublishAbortAfterCrashEventForLocallyCheckedCronJobs()
      • shouldPublishAbortAfterCrashEventWhenUsingActiveNodeIds

        public void shouldPublishAbortAfterCrashEventWhenUsingActiveNodeIds()
      • shouldPublishAbortAfterCrashEventWhenUsingOnlyActiveNodeIds

        public void shouldPublishAbortAfterCrashEventWhenUsingOnlyActiveNodeIds()