com.novemberain.quartz.mongodb.cluster

Class TriggerRecoverer

java.lang.Object

com.novemberain.quartz.mongodb.cluster.TriggerRecoverer

public class TriggerRecoverer
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
TriggerRecoverer(LocksDao locksDao, TriggerAndJobPersister persister, LockManager lockManager, TriggerDao triggerDao, JobDao jobDao, RecoveryTriggerFactory recoveryTriggerFactory, MisfireHandler misfireHandler)

Method Summary

Modifier and Type	Method and Description
org.quartz.spi.OperableTrigger	doRecovery(org.quartz.spi.OperableTrigger trigger) Do recovery procedure after failed run of given trigger.
void	recover()

Methods inherited from class java.lang.Object

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

Constructor Detail

TriggerRecoverer

public TriggerRecoverer(LocksDao locksDao,
                        TriggerAndJobPersister persister,
                        LockManager lockManager,
                        TriggerDao triggerDao,
                        JobDao jobDao,
                        RecoveryTriggerFactory recoveryTriggerFactory,
                        MisfireHandler misfireHandler)

Method Detail

recover

public void recover()
             throws org.quartz.JobPersistenceException

Throws:

org.quartz.JobPersistenceException

doRecovery

public org.quartz.spi.OperableTrigger doRecovery(org.quartz.spi.OperableTrigger trigger)
                                          throws org.quartz.JobPersistenceException

Do recovery procedure after failed run of given trigger.

Parameters:

trigger - trigger to recover

Returns:

recovery trigger or null if its job doesn't want that

Throws:

org.quartz.JobPersistenceException