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

Modifier and Type	Class	Description
static class	StaleCronJobUnlockerTest.TestStaleCronJobUnlocker.Builder

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

Method Summary

Modifier and Type	Method	Description
static StaleCronJobUnlockerTest.TestStaleCronJobUnlocker.Builder	forCurrentTenant()
static StaleCronJobUnlockerTest.TestStaleCronJobUnlocker.Builder	forTenant(Tenant tenant)
protected java.util.Collection<ClusterNodeInfo>	getAllNodes()
protected java.util.List<java.lang.Integer>	getNodeIds(java.util.Collection<ClusterNodeInfo> nodes)
protected java.util.List<java.lang.Integer>	getStaleNodeIds(java.util.Collection<ClusterNodeInfo> allNodes, java.util.function.Predicate<ClusterNodeInfo> staleNodePredicate)
protected void	unlockCronJobsForNodeIds(java.util.Collection<java.lang.Integer> staleNodes, java.util.Collection<java.lang.Integer> allNodes)
protected void	unlockCronJobsFromLocalInstance()

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

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

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

Method Detail

forCurrentTenant

public static StaleCronJobUnlockerTest.TestStaleCronJobUnlocker.Builder forCurrentTenant()

forTenant

public static StaleCronJobUnlockerTest.TestStaleCronJobUnlocker.Builder forTenant(Tenant tenant)

getStaleNodeIds

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

Overrides:

getStaleNodeIds in class StaleCronJobUnlocker

unlockCronJobsForNodeIds

protected void unlockCronJobsForNodeIds(java.util.Collection<java.lang.Integer> staleNodes,
                                        java.util.Collection<java.lang.Integer> allNodes)

Overrides:

unlockCronJobsForNodeIds in class StaleCronJobUnlocker

unlockCronJobsFromLocalInstance

protected void unlockCronJobsFromLocalInstance()

Overrides:

unlockCronJobsFromLocalInstance in class StaleCronJobUnlocker

getNodeIds

protected java.util.List<java.lang.Integer> getNodeIds(java.util.Collection<ClusterNodeInfo> nodes)

Overrides:

getNodeIds in class StaleCronJobUnlocker

getAllNodes

protected java.util.Collection<ClusterNodeInfo> getAllNodes()

Overrides:

getAllNodes in class StaleCronJobUnlocker