项目关闭时从last_instance_active_time HASH中移除本机

[cyao2q]

No description provided.

[cyao2q]

package com.cyao.schedule.jobstore;

import net.joelinn.quartz.jobstore.RedisJobStoreSchema;
import org.quartz.JobPersistenceException;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

/**
 * 重写RedisJobStore的shutdown方法保证项目关闭时从redis清除当前instanceId
 *
 * @author Cyao
 */
public class RedisJobStore extends net.joelinn.quartz.jobstore.RedisJobStore {
    private Logger logger = LoggerFactory.getLogger(getClass());

    @Override
    public void shutdown() {
        logger.info("RedisJobStore_$_{} shutting down.", instanceId);
        final RedisJobStoreSchema redisSchema = new RedisJobStoreSchema(keyPrefix, keyDelimiter);
        try {
            super.doWithLock(jedis -> jedis.hdel(redisSchema.lastInstanceActiveTime(), instanceId));
        } catch (JobPersistenceException e) {
            e.printStackTrace();
        }
        super.shutdown();
        logger.info("RedisJobStore_$_{} shutdown complete.", instanceId);
    }
}