Class JobDao


  • public class JobDao
    extends java.lang.Object
    • Constructor Summary

      Constructors 
      Constructor Description
      JobDao​(com.mongodb.client.MongoCollection<org.bson.Document> jobCollection, QueryHelper queryHelper, JobConverter jobConverter)  
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method 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