fix "Can not find Subscriptions: 'bus.cluman.errors'"

codeabovelab · Oct 28, 2017 · c49d57f · c49d57f
1 parent ff1bc6d
commit c49d57f
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/cluster-manager/src/main/java/com/codeabovelab/dm/cluman/ui/msg/EventSources.java b/cluster-manager/src/main/java/com/codeabovelab/dm/cluman/ui/msg/EventSources.java
@@ -34,6 +34,7 @@
 import com.codeabovelab.dm.common.security.Action;
 import com.codeabovelab.dm.cluman.security.TempAuth;
 import com.codeabovelab.dm.common.utils.Closeables;
+import com.google.common.collect.ImmutableMap;
 import com.google.common.util.concurrent.ThreadFactoryBuilder;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -107,6 +108,8 @@ private <T> void addStats(Subscriptions<T> subscriptions, String busId, Function
     public void init() {
         ThreadFactory tf = new ThreadFactoryBuilder().setDaemon(true).setNameFormat(getClass().getSimpleName() + "-%d").build();
         executor = Executors.newCachedThreadPool(tf);
+        // load system subs, it fix issue: "Can not find Subscriptions: 'bus.cluman.errors'"
+        subs.set(ImmutableMap.copyOf(systemSubs));
     }
 
     @PreDestroy
@@ -143,6 +146,7 @@ private void load() {
             subs.compareAndSet(esuc.getOldMap(), esuc.getNewMap());
             //close outdated subscriptions (do not put it in finally block)
             esuc.free();
+            lastUpdate = System.currentTimeMillis();
         } finally {
             lock.unlock();
         }