Package com.netgrif.quartz.mongodb.dao

Class TriggerDao

  • public class TriggerDao
extends java.lang.Object

    • Constructor Summary

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

    • Method Summary

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