Package de.hybris.platform.cronjob
Class StaleCronJobUnlockerTest.TestStaleCronJobUnlocker
java.lang.Object
java.lang.Thread
de.hybris.platform.core.threadregistry.RegistrableThread
de.hybris.platform.cronjob.StaleCronJobUnlocker
de.hybris.platform.cronjob.StaleCronJobUnlockerTest.TestStaleCronJobUnlocker
- All Implemented Interfaces:
Runnable
- Enclosing class:
- StaleCronJobUnlockerTest
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionstatic classNested classes/interfaces inherited from class java.lang.Thread
Thread.State, Thread.UncaughtExceptionHandler -
Field Summary
Fields inherited from class de.hybris.platform.cronjob.StaleCronJobUnlocker
PROPERTY_CRONJOB_STALE_NODE_CUTOFF_INTERVAL, PROPERTY_CRONJOB_STALE_NODE_INTERVAL, PROPERTY_CRONJOB_UNLOCK_LIMIT, PROPERTY_CRONJOB_UNLOCKER_ACTIVE, PROPERTY_CRONJOB_UNLOCKER_INTERVALFields inherited from class java.lang.Thread
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY -
Method Summary
Modifier and TypeMethodDescriptionprotected Collection<ClusterNodeInfo>getNodeIds(Collection<ClusterNodeInfo> nodes) getStaleNodeIds(Collection<ClusterNodeInfo> allNodes, Predicate<ClusterNodeInfo> staleNodePredicate) protected voidunlockCronJobsForNodeIds(Collection<Integer> staleNodes, Collection<Integer> allNodes) protected voidMethods inherited from class de.hybris.platform.cronjob.StaleCronJobUnlocker
getCheckIntervalMs, getMaxCronJobsCountToBeUnlocked, getStaleNodeIds, getStaleNodePredicate, getStaleNodeThresholdInterval, getStaleNodeTsCutoff, getStaleNodeTsThreshold, internalRun, shouldUnlockStaleCronJobs, stopUpdatingAndFinish, unlockCronJobsForNodeIdsMethods inherited from class de.hybris.platform.core.threadregistry.RegistrableThread
registerThread, run, unregisterThread, withInitialInfoMethods inherited from class java.lang.Thread
activeCount, checkAccess, clone, countStackFrames, currentThread, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, onSpinWait, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, suspend, toString, yield
-
Method Details
-
forCurrentTenant
-
forTenant
-
getStaleNodeIds
protected List<Integer> getStaleNodeIds(Collection<ClusterNodeInfo> allNodes, Predicate<ClusterNodeInfo> staleNodePredicate) - Overrides:
getStaleNodeIdsin classStaleCronJobUnlocker
-
unlockCronJobsForNodeIds
protected void unlockCronJobsForNodeIds(Collection<Integer> staleNodes, Collection<Integer> allNodes) - Overrides:
unlockCronJobsForNodeIdsin classStaleCronJobUnlocker
-
unlockCronJobsFromLocalInstance
protected void unlockCronJobsFromLocalInstance()- Overrides:
unlockCronJobsFromLocalInstancein classStaleCronJobUnlocker
-
getNodeIds
- Overrides:
getNodeIdsin classStaleCronJobUnlocker
-
getAllNodes
- Overrides:
getAllNodesin classStaleCronJobUnlocker
-