src/main/java/com/redislabs/quartz/RedisJobStore.java
/**
	 * Release blocked jobs, blocked by the given instance id.
	 *
	 * @param blockedByInstanceId the blocking instance id
	 */
Release blocked jobs, blocked by the given instance id.
@param blockedByInstanceId the blocking instance id
Release blocked jobs blocked by the given instance id . @param blockedByInstanceId the blocking instance id
private void releaseBlockedJobs(String blockedByInstanceId) {
      try (Jedis jedis = pool.getResource()) {
         lockPool.acquire();
			Set<String> blockedJobs = jedis.smembers(BLOCKED_JOBS_SET)	;
			for (String blockedJob : blockedJobs) {
				if (blockedByInstanceId != null && blockedByInstanceId.equals(jedis.hget(blockedJob, BLOCKED_BY))) {
					jedis.hset(blockedJob, BLOCKED_BY, "");
                	jedis.hset(blockedJob, BLOCK_TIME, "");
					jedis.srem(BLOCKED_JOBS_SET, blockedJob);
				}					
			}
		} catch (Exception ex) {
			log.error("could not release blocked jobs", ex);
		} finally {
         lockPool.release();
		}
	}
private void releaseBlockedJobs ( String blockedByInstanceId ) { try ( Jedis jedis = pool . getResource ( ) ) { lockPool . acquire ( ) ; Set < String > blockedJobs = jedis . smembers ( BLOCKED_JOBS_SET ) ; for ( String blockedJob : blockedJobs ) { if ( blockedByInstanceId != null && blockedByInstanceId . equals ( jedis . hget ( blockedJob , BLOCKED_BY ) ) ) { jedis . hset ( blockedJob , BLOCKED_BY , "" ) ; jedis . hset ( blockedJob , BLOCK_TIME , "" ) ; jedis . srem ( BLOCKED_JOBS_SET , blockedJob ) ; } } } catch ( Exception ex ) { log . error ( "could not release blocked jobs" , ex ) ; } finally { lockPool . release ( ) ; } }
Release blocked jobs, blocked by the given instance id.
Release blocked jobs blocked by the given instance id .