https://github.com/apache/incubator-dubbo/blob/3e9b66854c6f70b1dfa7dd19e689bd04ae0ecb41/dubbo-registry/dubbo-registry-redis/src/main/java/com/alibaba/dubbo/registry/redis/RedisRegistry.java#L590

https://github.com/apache/incubator-dubbo/blob/3e9b66854c6f70b1dfa7dd19e689bd04ae0ecb41/dubbo-registry/dubbo-registry-redis/src/main/java/com/alibaba/dubbo/registry/redis/RedisRegistry.java#L602

Just read the RedisRegistry.java and got doubtful about the above lines. Is the following code more appropriate ?

```
if (first) {
   // blah blah												
} 
```



jedis.close();
                    }
                } catch (Throwable t) { // 
                    logger.error(t.getMessage(), t);
                }
            }
        }
        @Override
        public void onPMessage(String pattern, String key, String msg) {
            onMessage(key, msg);
        }
        @Override
        public void onSubscribe(String key, int num) {
        }
        @Override
        public void onPSubscribe(String pattern, int num) {
        }
        @Override
        public void onUnsubscribe(String key, int num) {
        }
        @Override
        public void onPUnsubscribe(String pattern, int num) {
        }
    }
    private class Notifier extends Thread {
        private final String service;
        private final AtomicInteger connectSkip = new AtomicInteger();
        private final AtomicInteger connectSkipped = new AtomicInteger();
        private volatile Jedis jedis;
        private volatile boolean first = true;