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:

java.lang.Runnable

Enclosing class:

StaleCronJobUnlockerTest

public static class StaleCronJobUnlockerTest.TestStaleCronJobUnlocker
extends StaleCronJobUnlocker

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

java.lang.Thread.State, java.lang.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_INTERVAL

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor	Description
TestStaleCronJobUnlocker(Tenant tenant, java.util.function.Function<java.util.function.Predicate<ClusterNodeInfo>,java.util.List<java.lang.Integer>> getStaleNodeIdsFunction)

Method Summary

Modifier and Type	Method	Description
protected java.util.List<java.lang.Integer>	getStaleNodeIds(java.util.function.Predicate<ClusterNodeInfo> staleNodePredicate)
protected void	unlockCronJobsForNodeIds(java.util.List<java.lang.Integer> staleNodes)

Methods inherited from class de.hybris.platform.cronjob.StaleCronJobUnlocker

getCheckIntervalMs, getMaxCronJobsCountToBeUnlocked, getStaleNodePredicate, getStaleNodeThresholdInterval, getStaleNodeTsCutoff, getStaleNodeTsThreshold, internalRun, shouldUnlockStaleCronJobs, stopUpdatingAndFinish

Methods inherited from class de.hybris.platform.core.threadregistry.RegistrableThread

registerThread, run, unregisterThread, withInitialInfo

Methods 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

Methods inherited from class java.lang.Object

equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

TestStaleCronJobUnlocker

public TestStaleCronJobUnlocker(Tenant tenant,
                                java.util.function.Function<java.util.function.Predicate<ClusterNodeInfo>,java.util.List<java.lang.Integer>> getStaleNodeIdsFunction)

Method Detail

getStaleNodeIds

protected java.util.List<java.lang.Integer> getStaleNodeIds(java.util.function.Predicate<ClusterNodeInfo> staleNodePredicate)

Overrides:

getStaleNodeIds in class StaleCronJobUnlocker

unlockCronJobsForNodeIds

protected void unlockCronJobsForNodeIds(java.util.List<java.lang.Integer> staleNodes)

Overrides:

unlockCronJobsForNodeIds in class StaleCronJobUnlocker