src/main/java/com/redislabs/quartz/RedisJobStore.java
/**
	 * Resume a trigger in redis.
	 *
	 * @param trigger the trigger
	 * @param jedis thread-safe redis connection
	 * @throws JobPersistenceException
	 */
Resume a trigger in redis.
@param trigger the trigger
@param jedis thread-safe redis connection
@throws JobPersistenceException
Resume a trigger in redis . @param trigger the trigger @param jedis thread - safe redis connection @throws JobPersistenceException
private void resumeTrigger(OperableTrigger trigger, Jedis jedis) throws JobPersistenceException {
		String triggerHashKey = createTriggerHashKey(trigger.getKey().getGroup(), trigger.getKey().getName());
		if (!jedis.sismember(TRIGGERS_SET, triggerHashKey))
			throw new JobPersistenceException("trigger: " + trigger + " does not exist");
		if (jedis.zscore(RedisTriggerState.PAUSED.getKey(), triggerHashKey) == null && jedis.zscore(RedisTriggerState.PAUSED_BLOCKED.getKey(), triggerHashKey) == null)
			throw new JobPersistenceException("trigger: " + trigger + " is not paused");
		String jobHashKey = createJobHashKey(trigger.getJobKey().getGroup(), trigger.getJobKey().getName());
		Date nextFireTime = trigger.getNextFireTime();
		if (nextFireTime != null) {
			if (jedis.sismember(BLOCKED_JOBS_SET, jobHashKey))
				setTriggerState(RedisTriggerState.BLOCKED, (double)nextFireTime.getTime(), triggerHashKey);
			else
				setTriggerState(RedisTriggerState.WAITING, (double)nextFireTime.getTime(), triggerHashKey);
		}
	}
private void resumeTrigger ( OperableTrigger trigger , Jedis jedis ) throws JobPersistenceException { String triggerHashKey = createTriggerHashKey ( trigger . getKey ( ) . getGroup ( ) , trigger . getKey ( ) . getName ( ) ) ; if ( ! jedis . sismember ( TRIGGERS_SET , triggerHashKey ) ) throw new JobPersistenceException ( "trigger: " + trigger + " does not exist" ) ; if ( jedis . zscore ( RedisTriggerState . PAUSED . getKey ( ) , triggerHashKey ) == null && jedis . zscore ( RedisTriggerState . PAUSED_BLOCKED . getKey ( ) , triggerHashKey ) == null ) throw new JobPersistenceException ( "trigger: " + trigger + " is not paused" ) ; String jobHashKey = createJobHashKey ( trigger . getJobKey ( ) . getGroup ( ) , trigger . getJobKey ( ) . getName ( ) ) ; Date nextFireTime = trigger . getNextFireTime ( ) ; if ( nextFireTime != null ) { if ( jedis . sismember ( BLOCKED_JOBS_SET , jobHashKey ) ) setTriggerState ( RedisTriggerState . BLOCKED , ( double ) nextFireTime . getTime ( ) , triggerHashKey ) ; else setTriggerState ( RedisTriggerState . WAITING , ( double ) nextFireTime . getTime ( ) , triggerHashKey ) ; } }
Resume a trigger in redis.
Resume a trigger in redis .