private void deferExpired()

in dubbo-registry-extensions/dubbo-registry-redis/src/main/java/org/apache/dubbo/registry/redis/RedisRegistry.java [139:160]

• 20 lines of code
• 8 McCabe index (conditional complexity)

    private void deferExpired() {
        for (URL url : new HashSet<>(getRegistered())) {
            if (url.getParameter(DYNAMIC_KEY, true)) {
                String key = toCategoryPath(url);
                if (redisClient.hset(key, url.toFullString(), String.valueOf(System.currentTimeMillis() + expirePeriod)) == 1) {
                    redisClient.publish(key, REGISTER);
                }
            }
        }

        if (doExpire) {
            for (Map.Entry<URL, Long> expireEntry : expireCache.entrySet()) {
                if (expireEntry.getValue() < System.currentTimeMillis()) {
                    doNotify(toCategoryPath(expireEntry.getKey()));
                }
            }
        }

        if (admin) {
            clean();
        }
    }