Package com.atlassian.crowd.scheduling

Class ClusterJobDAODecorator

java.lang.Object

com.atlassian.crowd.scheduling.ClusterJobDAODecorator

All Implemented Interfaces:

com.atlassian.scheduler.caesium.spi.ClusteredJobDao

public class ClusterJobDAODecorator
extends Object
implements com.atlassian.scheduler.caesium.spi.ClusteredJobDao

Handles conversion between Crowd's InternalClusterJob and Caesium's ClusteredJobs.

Constructor Summary

Constructors

Constructor	Description
ClusterJobDAODecorator(ClusterJobDAOHibernate dao, Supplier<String> nodeIdSupplier)

Method Summary

Modifier and Type	Method	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)
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 java.lang.Object

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

Methods inherited from interface com.atlassian.scheduler.caesium.spi.ClusteredJobDao

findByJobRunnerKeys

Constructor Details

ClusterJobDAODecorator

public ClusterJobDAODecorator(ClusterJobDAOHibernate dao,
 Supplier<String> nodeIdSupplier)

Method Details

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