com.novemberain.quartz.mongodb

Class LockManager

java.lang.Object

com.novemberain.quartz.mongodb.LockManager

public class LockManager
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
LockManager(LocksDao locksDao, ExpiryCalculator expiryCalculator)

Method Summary

Modifier and Type	Method and Description
void	lockJob(org.quartz.JobDetail job) Lock job if it doesn't allow concurrent executions.
boolean	relockExpired(org.quartz.TriggerKey key) Relock trigger if its lock has expired.
boolean	tryLock(org.quartz.TriggerKey key) Try to lock given trigger, ignoring errors.
void	unlockAcquiredTrigger(org.quartz.spi.OperableTrigger trigger)
void	unlockExpired(org.quartz.JobDetail job) Unlock job that have existing, expired lock.

Methods inherited from class java.lang.Object

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

Constructor Detail

LockManager

public LockManager(LocksDao locksDao,
                   ExpiryCalculator expiryCalculator)

Method Detail

lockJob

public void lockJob(org.quartz.JobDetail job)

Lock job if it doesn't allow concurrent executions.

Parameters:

job - job to lock

unlockAcquiredTrigger

public void unlockAcquiredTrigger(org.quartz.spi.OperableTrigger trigger)

unlockExpired

public void unlockExpired(org.quartz.JobDetail job)

Unlock job that have existing, expired lock.

Parameters:

job - job to potentially unlock

tryLock

public boolean tryLock(org.quartz.TriggerKey key)

Try to lock given trigger, ignoring errors.

Parameters:

key - trigger to lock

Returns:

true when successfully locked, false otherwise

relockExpired

public boolean relockExpired(org.quartz.TriggerKey key)

Relock trigger if its lock has expired.

Parameters:

key - trigger to lock

Returns:

true when successfully relocked