Package io.jmix.quartz.service

Class RunningJobsCache

java.lang.Object

io.jmix.quartz.service.RunningJobsCache

@Component("quartz_RunningJobsCache")
public class RunningJobsCache
extends Object

Currently running jobs store

Field Summary

Fields

Modifier and Type	Field	Description
static final String	CACHE_NAME
protected org.springframework.cache.CacheManager	cacheManager
protected CacheOperations	cacheOperations
protected org.springframework.cache.Cache	jobDetails

Constructor Summary

Constructors

Constructor	Description
RunningJobsCache()

Method Summary

Modifier and Type	Method	Description
Set<org.quartz.TriggerKey>	getRunningTriggers(org.quartz.JobKey key)
protected void	init()
void	invalidate(org.quartz.JobKey jobKey)	Remove all running triggers for provided job from cache
void	invalidate(org.quartz.JobKey jobKey, org.quartz.TriggerKey triggerKey)
void	invalidateAll()	Invalidate entire cache
boolean	isJobRunning(org.quartz.JobKey jobKey)	Checks if job has at least one running trigger
void	put(org.quartz.JobKey jobKey, org.quartz.TriggerKey triggerKey)

Methods inherited from class java.lang.Object

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

Field Details

jobDetails

protected org.springframework.cache.Cache jobDetails

cacheManager

@Autowired
protected org.springframework.cache.CacheManager cacheManager

cacheOperations

@Autowired
protected CacheOperations cacheOperations

CACHE_NAME

public static final String CACHE_NAME

See Also:

• Constant Field Values

Constructor Details

RunningJobsCache

public RunningJobsCache()

Method Details

init

@PostConstruct
protected void init()

isJobRunning

public boolean isJobRunning(org.quartz.JobKey jobKey)

Checks if job has at least one running trigger

Parameters:

jobKey - Job key

Returns:

true if there is running trigger, false otherwise.

getRunningTriggers

public Set<org.quartz.TriggerKey> getRunningTriggers(org.quartz.JobKey key)

put

public void put(org.quartz.JobKey jobKey,
 org.quartz.TriggerKey triggerKey)

invalidate

public void invalidate(org.quartz.JobKey jobKey,
 org.quartz.TriggerKey triggerKey)

invalidate

public void invalidate(org.quartz.JobKey jobKey)

Remove all running triggers for provided job from cache

Parameters:

jobKey - Job key

invalidateAll

public void invalidateAll()

Invalidate entire cache