com.atlassian.confluence.impl.schedule.caesium

Class SchedulerClusteredJobDao

java.lang.Object

org.springframework.dao.support.DaoSupport

com.atlassian.confluence.core.persistence.hibernate.HibernateObjectDao

com.atlassian.confluence.core.persistence.hibernate.VersionedHibernateObjectDao

com.atlassian.confluence.core.persistence.hibernate.ConfluenceHibernateObjectDao

com.atlassian.confluence.impl.schedule.caesium.SchedulerClusteredJobDao

All Implemented Interfaces:

ObjectDao, VersionedObjectDao, com.atlassian.scheduler.caesium.spi.ClusteredJobDao, org.springframework.beans.factory.InitializingBean

public class SchedulerClusteredJobDao
extends ConfluenceHibernateObjectDao
implements com.atlassian.scheduler.caesium.spi.ClusteredJobDao

See SchedulerClusteredJobDaoProxyWrapper.

Since:

5.10

Nested Class Summary

Nested classes/interfaces inherited from class com.atlassian.confluence.core.persistence.hibernate.HibernateObjectDao

HibernateObjectDao.Cacheability

Field Summary

Fields inherited from class com.atlassian.confluence.core.persistence.hibernate.VersionedHibernateObjectDao

cacheFactory, confluenceUserDao

Fields inherited from class org.springframework.dao.support.DaoSupport

logger

Fields inherited from interface bucket.core.persistence.ObjectDao

NON_CACHEABLE

Constructor Summary

Constructors

Constructor and Description
SchedulerClusteredJobDao()

Method Summary

Modifier and Type	Method and Description
boolean	create(com.atlassian.scheduler.caesium.spi.ClusteredJob clusteredJob)
boolean	delete(com.atlassian.scheduler.config.JobId jobId)
com.atlassian.scheduler.caesium.spi.ClusteredJob	find(com.atlassian.scheduler.config.JobId jobId)
Set<com.atlassian.scheduler.config.JobRunnerKey>	findAllJobRunnerKeys()
Collection<com.atlassian.scheduler.caesium.spi.ClusteredJob>	findByJobRunnerKey(com.atlassian.scheduler.config.JobRunnerKey jobRunnerKey)
Date	getNextRunTime(com.atlassian.scheduler.config.JobId jobId)
Class	getPersistentClass()
Long	getVersion(com.atlassian.scheduler.config.JobId jobId)
Map<com.atlassian.scheduler.config.JobId,Date>	refresh()
boolean	updateNextRunTime(com.atlassian.scheduler.config.JobId jobId, Date nextRunTime, long expectedVersion)

Methods inherited from class com.atlassian.confluence.core.persistence.hibernate.VersionedHibernateObjectDao

findAllSorted, findLatestVersionsCount, findLatestVersionsCount, findLatestVersionsIterator, findLatestVersionsIterator, findNamedQueryStringParams, findNamedQueryStringParams, save, setCacheFactory, setConfluenceUserDao, updateModificationData

Methods inherited from class com.atlassian.confluence.core.persistence.hibernate.HibernateObjectDao

applyTransactionTimeout, applyTransactionTimeout, checkDaoConfig, createHibernateTemplate, findAll, findAllSorted, findByClassIds, findNamedQuery, findNamedQuery, findNamedQuery, findNamedQuery, findNamedQuery, findNamedQueryStringParam, findNamedQueryStringParam, findNamedQueryStringParam, findNamedQueryStringParam, findNamedQueryStringParam, findNamedQueryStringParams, findNamedQueryStringParams, findNamedQueryStringParams, findNamedQueryStringParams, findNamedQueryStringParams, findNamedQueryStringParams, findNamedQueryStringParams, findNamedQueryStringParams, findNamedQueryStringParams, findNamedQueryStringParams, findNamedQueryStringParams, findNamedQueryStringParams, findNamedQueryStringParams, findNamedQueryStringParams, findNamedQueryStringParams, findNamedQueryStringParams, findNamedQueryStringParams, findSingleObject, getByClassId, getCountResult, getHibernateTemplate, getSession, getSessionFactory, index, refresh, reIndex, remove, replicate, save, saveRaw, setHibernateTemplate, setIndexer, setSessionFactory, unIndex, uniqueResult

Methods inherited from class org.springframework.dao.support.DaoSupport

afterPropertiesSet, initDao

Methods inherited from class java.lang.Object

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

Methods inherited from interface bucket.core.persistence.ObjectDao

findAll, findAllSorted, findByClassIds, refresh, remove, replicate, save, saveRaw

Constructor Detail

SchedulerClusteredJobDao

public SchedulerClusteredJobDao()

Method Detail

getPersistentClass

public Class getPersistentClass()

Specified by:

getPersistentClass in interface ObjectDao

getNextRunTime

@Nullable
public Date getNextRunTime(com.atlassian.scheduler.config.JobId jobId)

Specified by:

getNextRunTime in interface com.atlassian.scheduler.caesium.spi.ClusteredJobDao

getVersion

@Nullable
public Long getVersion(com.atlassian.scheduler.config.JobId jobId)

Specified by:

getVersion in interface com.atlassian.scheduler.caesium.spi.ClusteredJobDao

find

@Nullable
public com.atlassian.scheduler.caesium.spi.ClusteredJob find(com.atlassian.scheduler.config.JobId jobId)

Specified by:

find in interface com.atlassian.scheduler.caesium.spi.ClusteredJobDao

findByJobRunnerKey

@Nonnull
public Collection<com.atlassian.scheduler.caesium.spi.ClusteredJob> findByJobRunnerKey(com.atlassian.scheduler.config.JobRunnerKey jobRunnerKey)

Specified by:

findByJobRunnerKey in interface com.atlassian.scheduler.caesium.spi.ClusteredJobDao

refresh

@Nonnull
public Map<com.atlassian.scheduler.config.JobId,Date> refresh()

Specified by:

refresh in interface com.atlassian.scheduler.caesium.spi.ClusteredJobDao

findAllJobRunnerKeys

@Nonnull
public Set<com.atlassian.scheduler.config.JobRunnerKey> findAllJobRunnerKeys()

Specified by:

findAllJobRunnerKeys in interface com.atlassian.scheduler.caesium.spi.ClusteredJobDao

create

public boolean create(com.atlassian.scheduler.caesium.spi.ClusteredJob clusteredJob)

Specified by:

create in interface com.atlassian.scheduler.caesium.spi.ClusteredJobDao

updateNextRunTime

public boolean updateNextRunTime(com.atlassian.scheduler.config.JobId jobId,
                                 @Nullable
                                 Date nextRunTime,
                                 long expectedVersion)

Specified by:

updateNextRunTime in interface com.atlassian.scheduler.caesium.spi.ClusteredJobDao

delete

public boolean delete(com.atlassian.scheduler.config.JobId jobId)

Specified by:

delete in interface com.atlassian.scheduler.caesium.spi.ClusteredJobDao