|
@@ -20,6 +20,7 @@ import com.ctrip.framework.apollo.core.utils.ApolloThreadFactory;
|
|
|
import com.google.common.collect.LinkedListMultimap;
|
|
|
import com.google.common.collect.Maps;
|
|
|
import com.google.common.collect.Multimap;
|
|
|
+import com.google.common.collect.Multimaps;
|
|
|
import java.util.Collection;
|
|
|
import java.util.Iterator;
|
|
|
import java.util.Map;
|
|
@@ -28,10 +29,13 @@ import java.util.concurrent.Executors;
|
|
|
import java.util.concurrent.TimeUnit;
|
|
|
import java.util.concurrent.atomic.AtomicBoolean;
|
|
|
|
|
|
-import com.google.common.collect.Multimaps;
|
|
|
+import org.slf4j.Logger;
|
|
|
+import org.slf4j.LoggerFactory;
|
|
|
import org.springframework.beans.factory.BeanFactory;
|
|
|
|
|
|
public class SpringValueRegistry {
|
|
|
+ private static final Logger logger = LoggerFactory.getLogger(SpringValueRegistry.class);
|
|
|
+
|
|
|
private static final long CLEAN_INTERVAL_IN_SECONDS = 5;
|
|
|
private final Map<BeanFactory, Multimap<String, SpringValue>> registry = Maps.newConcurrentMap();
|
|
|
private final AtomicBoolean initialized = new AtomicBoolean(false);
|
|
@@ -70,7 +74,7 @@ public class SpringValueRegistry {
|
|
|
try {
|
|
|
scanAndClean();
|
|
|
} catch (Throwable ex) {
|
|
|
- ex.printStackTrace();
|
|
|
+ logger.error(ex.getMessage(), ex);
|
|
|
}
|
|
|
}
|
|
|
}, CLEAN_INTERVAL_IN_SECONDS, CLEAN_INTERVAL_IN_SECONDS, TimeUnit.SECONDS);
|