mindwind / craft-atom Goto Github PK

try {
       s.slaveof(m.host(), m.port());
     } catch (RedisConnectionException e) {
    LOG.warn("[CRAFT-ATOM-REDIS] {} slaveof {} failed", s.toString(), m.toString());
}

    Jedis j = jedis();
    try {
        // invoke jedis api to execute redis command
    } catch (Exception e) {
        RedisException re = handleException(e, j, args);
        j = null;
        throw re;
    } finally {
       release(j);
    }

    RedisException handleException(Exception e, Jedis j, Object... args) {
        unbind();

        if (e instanceof JedisConnectionException) {
            if (j != null) {
                pool.returnBrokenResource(j);
            }
            return new RedisConnectionException(String.format("Connect to redis server<host=%s, port=%s> failed.", host, port), e);
        }

        if (e instanceof JedisDataException) {
            return new RedisDataException(String.format("Redis data <args=%s> process failed.", Arrays.toString(args)), e);
        }

        return new RedisException(e);
    }

    private void release(Jedis j) {
        if (isBound()) {
            // in transaction context don't return jedis connection to pool.
            return;
        } else {
            if (j != null) {
                pool.returnResource(j);
            }
        }
    }