com.novemberain.quartz.mongodb.dao

Class JobDao

java.lang.Object

com.novemberain.quartz.mongodb.dao.JobDao

public class JobDao
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
JobDao(com.mongodb.client.MongoCollection<org.bson.Document> jobCollection, QueryHelper queryHelper, JobConverter jobConverter)

Method Summary

Modifier and Type	Method and Description
com.mongodb.client.result.DeleteResult	clear()
void	createIndex()
void	dropIndex()
boolean	exists(org.quartz.JobKey jobKey)
org.bson.Document	getById(java.lang.Object id)
com.mongodb.client.MongoCollection<org.bson.Document>	getCollection()
int	getCount()
java.util.List<java.lang.String>	getGroupNames()
org.bson.Document	getJob(org.bson.conversions.Bson keyObject)
org.bson.Document	getJob(org.quartz.JobKey key)
java.util.Set<org.quartz.JobKey>	getJobKeys(org.quartz.impl.matchers.GroupMatcher<org.quartz.JobKey> matcher)
java.util.Collection<org.bson.types.ObjectId>	idsOfMatching(org.quartz.impl.matchers.GroupMatcher<org.quartz.JobKey> matcher)
void	remove(org.bson.conversions.Bson keyObject)
boolean	requestsRecovery(org.quartz.JobKey jobKey)
org.quartz.JobDetail	retrieveJob(org.quartz.JobKey jobKey)
org.bson.types.ObjectId	storeJobInMongo(org.quartz.JobDetail newJob, boolean replaceExisting)

Methods inherited from class java.lang.Object

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

Constructor Detail

JobDao

public JobDao(com.mongodb.client.MongoCollection<org.bson.Document> jobCollection,
              QueryHelper queryHelper,
              JobConverter jobConverter)

Method Detail

getCollection

public com.mongodb.client.MongoCollection<org.bson.Document> getCollection()

clear

public com.mongodb.client.result.DeleteResult clear()

createIndex

public void createIndex()

dropIndex

public void dropIndex()

exists

public boolean exists(org.quartz.JobKey jobKey)

getById

public org.bson.Document getById(java.lang.Object id)

getJob

public org.bson.Document getJob(org.bson.conversions.Bson keyObject)

getJob

public org.bson.Document getJob(org.quartz.JobKey key)

getCount

public int getCount()

getGroupNames

public java.util.List<java.lang.String> getGroupNames()

getJobKeys

public java.util.Set<org.quartz.JobKey> getJobKeys(org.quartz.impl.matchers.GroupMatcher<org.quartz.JobKey> matcher)

idsOfMatching

public java.util.Collection<org.bson.types.ObjectId> idsOfMatching(org.quartz.impl.matchers.GroupMatcher<org.quartz.JobKey> matcher)

remove

public void remove(org.bson.conversions.Bson keyObject)

requestsRecovery

public boolean requestsRecovery(org.quartz.JobKey jobKey)

retrieveJob

public org.quartz.JobDetail retrieveJob(org.quartz.JobKey jobKey)
                                 throws org.quartz.JobPersistenceException

Throws:

org.quartz.JobPersistenceException

storeJobInMongo

public org.bson.types.ObjectId storeJobInMongo(org.quartz.JobDetail newJob,
                                               boolean replaceExisting)
                                        throws org.quartz.JobPersistenceException

Throws:

org.quartz.JobPersistenceException