com.novemberain.quartz.mongodb.dao

Class TriggerDao

java.lang.Object

com.novemberain.quartz.mongodb.dao.TriggerDao

public class TriggerDao
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
TriggerDao(com.mongodb.client.MongoCollection<org.bson.Document> triggerCollection, QueryHelper queryHelper, TriggerConverter triggerConverter)

Method Summary

Modifier and Type	Method and Description
void	clear()
void	createIndex()
void	dropIndex()
boolean	exists(org.bson.conversions.Bson filter)
com.mongodb.client.FindIterable<org.bson.Document>	findEligibleToRun(java.util.Date noLaterThanDate)
org.bson.Document	findTrigger(org.bson.conversions.Bson filter)
com.mongodb.client.MongoCollection<org.bson.Document>	getCollection()
int	getCount()
java.util.List<java.lang.String>	getGroupNames()
java.lang.String	getState(org.quartz.TriggerKey triggerKey)
org.quartz.spi.OperableTrigger	getTrigger(org.quartz.TriggerKey triggerKey)
java.util.Set<org.quartz.TriggerKey>	getTriggerKeys(org.quartz.impl.matchers.GroupMatcher<org.quartz.TriggerKey> matcher)
java.util.List<org.quartz.spi.OperableTrigger>	getTriggersForJob(org.bson.Document doc)
boolean	hasLastTrigger(org.bson.Document job)
void	insert(org.bson.Document trigger, org.quartz.Trigger offendingTrigger)
void	remove(org.bson.conversions.Bson filter)
void	remove(org.quartz.TriggerKey triggerKey)
void	removeByJobId(java.lang.Object id)
void	replace(org.quartz.TriggerKey triggerKey, org.bson.Document trigger)
void	setState(org.quartz.TriggerKey triggerKey, java.lang.String state)
void	setStateByJobId(org.bson.types.ObjectId jobId, java.lang.String state)
void	setStateInAll(java.lang.String state)
void	setStateInGroups(java.util.List<java.lang.String> groups, java.lang.String state)
void	setStateInMatching(org.quartz.impl.matchers.GroupMatcher<org.quartz.TriggerKey> matcher, java.lang.String state)
void	transferState(org.quartz.TriggerKey triggerKey, java.lang.String oldState, java.lang.String newState)

Methods inherited from class java.lang.Object

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

Constructor Detail

TriggerDao

public TriggerDao(com.mongodb.client.MongoCollection<org.bson.Document> triggerCollection,
                  QueryHelper queryHelper,
                  TriggerConverter triggerConverter)

Method Detail

createIndex

public void createIndex()

dropIndex

public void dropIndex()

clear

public void clear()

getCollection

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

exists

public boolean exists(org.bson.conversions.Bson filter)

findEligibleToRun

public com.mongodb.client.FindIterable<org.bson.Document> findEligibleToRun(java.util.Date noLaterThanDate)

findTrigger

public org.bson.Document findTrigger(org.bson.conversions.Bson filter)

getCount

public int getCount()

getGroupNames

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

getState

public java.lang.String getState(org.quartz.TriggerKey triggerKey)

getTrigger

public org.quartz.spi.OperableTrigger getTrigger(org.quartz.TriggerKey triggerKey)
                                          throws org.quartz.JobPersistenceException

Throws:

org.quartz.JobPersistenceException

getTriggersForJob

public java.util.List<org.quartz.spi.OperableTrigger> getTriggersForJob(org.bson.Document doc)
                                                                 throws org.quartz.JobPersistenceException

Throws:

org.quartz.JobPersistenceException

getTriggerKeys

public java.util.Set<org.quartz.TriggerKey> getTriggerKeys(org.quartz.impl.matchers.GroupMatcher<org.quartz.TriggerKey> matcher)

hasLastTrigger

public boolean hasLastTrigger(org.bson.Document job)

insert

public void insert(org.bson.Document trigger,
                   org.quartz.Trigger offendingTrigger)
            throws org.quartz.ObjectAlreadyExistsException

Throws:

org.quartz.ObjectAlreadyExistsException

remove

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

remove

public void remove(org.quartz.TriggerKey triggerKey)

removeByJobId

public void removeByJobId(java.lang.Object id)

replace

public void replace(org.quartz.TriggerKey triggerKey,
                    org.bson.Document trigger)

setState

public void setState(org.quartz.TriggerKey triggerKey,
                     java.lang.String state)

transferState

public void transferState(org.quartz.TriggerKey triggerKey,
                          java.lang.String oldState,
                          java.lang.String newState)

setStateInAll

public void setStateInAll(java.lang.String state)

setStateByJobId

public void setStateByJobId(org.bson.types.ObjectId jobId,
                            java.lang.String state)

setStateInGroups

public void setStateInGroups(java.util.List<java.lang.String> groups,
                             java.lang.String state)

setStateInMatching

public void setStateInMatching(org.quartz.impl.matchers.GroupMatcher<org.quartz.TriggerKey> matcher,
                               java.lang.String state)