src/main/java/com/redislabs/quartz/RedisJobStore.java
/**
	 * Retrieves trigger from redis.
	 *
	 * @param triggerKey the trigger key
	 * @param jedis thread-safe redis connection
	 * @return the operable trigger
	 * @throws JobPersistenceException
	 */
Retrieves trigger from redis.
@param triggerKey the trigger key
@param jedis thread-safe redis connection
@return the operable trigger
@throws JobPersistenceException
Retrieves trigger from redis . @param triggerKey the trigger key @param jedis thread - safe redis connection @return the operable trigger @throws JobPersistenceException
private OperableTrigger retrieveTrigger(TriggerKey triggerKey, Jedis jedis) throws JobPersistenceException {
		String triggerHashKey = createTriggerHashKey(triggerKey.getGroup(), triggerKey.getName());
		Map<String, String> trigger = jedis.hgetAll(triggerHashKey);
		if (!jedis.exists(triggerHashKey)) {
			log.debug("trigger does not exist for key: " + triggerHashKey);
			return null;
		}			
      if (!jedis.exists(trigger.get(JOB_HASH_KEY))) {
         log.warn("job: " + trigger.get(JOB_HASH_KEY) + " does not exist for trigger: " + triggerHashKey);
         return null;
      }
		return toOperableTrigger(triggerKey, trigger);
	}
private OperableTrigger retrieveTrigger ( TriggerKey triggerKey , Jedis jedis ) throws JobPersistenceException { String triggerHashKey = createTriggerHashKey ( triggerKey . getGroup ( ) , triggerKey . getName ( ) ) ; Map < String , String > trigger = jedis . hgetAll ( triggerHashKey ) ; if ( ! jedis . exists ( triggerHashKey ) ) { log . debug ( "trigger does not exist for key: " + triggerHashKey ) ; return null ; } if ( ! jedis . exists ( trigger . get ( JOB_HASH_KEY ) ) ) { log . warn ( "job: " + trigger . get ( JOB_HASH_KEY ) + " does not exist for trigger: " + triggerHashKey ) ; return null ; } return toOperableTrigger ( triggerKey , trigger ) ; }
Retrieves trigger from redis.
Retrieves trigger from redis .