public class TriggerDao
extends java.lang.Object
| Constructor and Description |
|---|
TriggerDao(com.mongodb.client.MongoCollection<org.bson.Document> triggerCollection,
QueryHelper queryHelper,
TriggerConverter triggerConverter) |
| 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) |
public TriggerDao(com.mongodb.client.MongoCollection<org.bson.Document> triggerCollection,
QueryHelper queryHelper,
TriggerConverter triggerConverter)
public void createIndex()
public void dropIndex()
public void clear()
public com.mongodb.client.MongoCollection<org.bson.Document> getCollection()
public boolean exists(org.bson.conversions.Bson filter)
public com.mongodb.client.FindIterable<org.bson.Document> findEligibleToRun(java.util.Date noLaterThanDate)
public org.bson.Document findTrigger(org.bson.conversions.Bson filter)
public int getCount()
public java.util.List<java.lang.String> getGroupNames()
public java.lang.String getState(org.quartz.TriggerKey triggerKey)
public org.quartz.spi.OperableTrigger getTrigger(org.quartz.TriggerKey triggerKey)
throws org.quartz.JobPersistenceException
org.quartz.JobPersistenceExceptionpublic java.util.List<org.quartz.spi.OperableTrigger> getTriggersForJob(org.bson.Document doc)
throws org.quartz.JobPersistenceException
org.quartz.JobPersistenceExceptionpublic java.util.Set<org.quartz.TriggerKey> getTriggerKeys(org.quartz.impl.matchers.GroupMatcher<org.quartz.TriggerKey> matcher)
public boolean hasLastTrigger(org.bson.Document job)
public void insert(org.bson.Document trigger,
org.quartz.Trigger offendingTrigger)
throws org.quartz.ObjectAlreadyExistsException
org.quartz.ObjectAlreadyExistsExceptionpublic void remove(org.bson.conversions.Bson filter)
public void remove(org.quartz.TriggerKey triggerKey)
public void removeByJobId(java.lang.Object id)
public void replace(org.quartz.TriggerKey triggerKey,
org.bson.Document trigger)
public void setState(org.quartz.TriggerKey triggerKey,
java.lang.String state)
public void transferState(org.quartz.TriggerKey triggerKey,
java.lang.String oldState,
java.lang.String newState)
public void setStateInAll(java.lang.String state)
public void setStateByJobId(org.bson.types.ObjectId jobId,
java.lang.String state)
public void setStateInGroups(java.util.List<java.lang.String> groups,
java.lang.String state)
public void setStateInMatching(org.quartz.impl.matchers.GroupMatcher<org.quartz.TriggerKey> matcher,
java.lang.String state)