com.atlassian.crowd.dao.scheduling

Class ClusterJobDAOHibernate

java.lang.Object

com.atlassian.crowd.util.persistence.hibernate.StatelessDao

com.atlassian.crowd.dao.scheduling.ClusterJobDAOHibernate

public class ClusterJobDAOHibernate
extends StatelessDao

Field Summary

Fields inherited from class com.atlassian.crowd.util.persistence.hibernate.StatelessDao

sessionFactory

Constructor Summary

Constructors

Constructor and Description
ClusterJobDAOHibernate()

Method Summary

Modifier and Type	Method and Description
boolean	claim(String id, Long nextRunTimestamp, long expectedVersion, String nodeId)
boolean	create(InternalClusterJob job)
boolean	delete(String id)
InternalClusterJob	find(String id)
Set<String>	findAllJobRunnerKeys()
Collection<InternalClusterJob>	findByJobRunnerKey(String jobRunnerKey)
Map<String,Date>	getIdsToNextRunTimes()
Date	getNextRunTime(String id)
Long	getVersion(String id)

Methods inherited from class com.atlassian.crowd.util.persistence.hibernate.StatelessDao

setSessionFactory, withStatelessSession

Methods inherited from class java.lang.Object

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

Constructor Detail

ClusterJobDAOHibernate

public ClusterJobDAOHibernate()

Method Detail

create

public boolean create(InternalClusterJob job)

find

public InternalClusterJob find(String id)

delete

public boolean delete(String id)

claim

public boolean claim(String id,
                     @Nullable
                     Long nextRunTimestamp,
                     long expectedVersion,
                     @Nullable
                     String nodeId)

getNextRunTime

public Date getNextRunTime(String id)

getVersion

public Long getVersion(String id)

findByJobRunnerKey

@Nonnull
public Collection<InternalClusterJob> findByJobRunnerKey(String jobRunnerKey)

getIdsToNextRunTimes

@Nonnull
public Map<String,Date> getIdsToNextRunTimes()

findAllJobRunnerKeys

@Nonnull
public Set<String> findAllJobRunnerKeys()