fix bean circle

ctripcorp · Oct 17, 2023 · 952b930 · 952b930
1 parent 712880d
commit 952b930
Show file tree

Hide file tree

Showing 2 changed files with 35 additions and 12 deletions.
diff --git a/...main/java/com/ctrip/xpipe/redis/checker/healthcheck/stability/DefaultStabilityHolder.java b/...main/java/com/ctrip/xpipe/redis/checker/healthcheck/stability/DefaultStabilityHolder.java
@@ -15,16 +15,16 @@ public class DefaultStabilityHolder implements StabilityHolder {
 
     private CheckerConfig config;
 
-    private boolean stable;
+    private boolean stable = true;
 
-    private long expiredAtMill;
+    private long expiredAtMill = 0L;
+
+    public DefaultStabilityHolder() {
+    }
 
-    @Autowired
     public DefaultStabilityHolder(StabilityInspector inspector, CheckerConfig config) {
         this.inspector = inspector;
         this.config = config;
-        this.stable = true;
-        this.expiredAtMill = 0L;
     }
 
     @Override
@@ -54,6 +54,16 @@ public void setStaticStable(boolean stable, int ttl) {
         this.expiredAtMill = System.currentTimeMillis() + (ttl * 1000);
     }
 
+    @Autowired
+    public void setInspector(StabilityInspector inspector) {
+        this.inspector = inspector;
+    }
+
+    @Autowired
+    public void setConfig(CheckerConfig config) {
+        this.config = config;
+    }
+
     @Override
     public void useDynamicStable() {
         this.expiredAtMill = 0;

diff --git a/...src/main/java/com/ctrip/xpipe/redis/checker/healthcheck/stability/StabilityInspector.java b/...src/main/java/com/ctrip/xpipe/redis/checker/healthcheck/stability/StabilityInspector.java
@@ -37,27 +37,26 @@ public class StabilityInspector extends AbstractLifecycle implements TopElement
 
     private CheckerConfig config;
 
-    private AtomicBoolean stable;
+    private AtomicBoolean stable = new AtomicBoolean(true);
 
-    private AtomicInteger continuousMismatchTimes;
+    private AtomicInteger continuousMismatchTimes = new AtomicInteger();
 
-    private AtomicInteger continuousNoInterested;
+    private AtomicInteger continuousNoInterested = new AtomicInteger();
 
     private DynamicDelayPeriodTask task;
 
     private ScheduledExecutorService scheduled;
 
     private static final String TYPE = "stability";
 
-    @Autowired
+    public StabilityInspector() {
+    }
+
     public StabilityInspector(DefaultDelayPingActionCollector defaultDelayPingActionCollector, MetaCache metaCache,
                               CheckerConfig checkerConfig) {
         this.collector = defaultDelayPingActionCollector;
         this.metaCache = metaCache;
         this.config = checkerConfig;
-        this.stable = new AtomicBoolean(true);
-        this.continuousMismatchTimes = new AtomicInteger();
-        this.continuousNoInterested = new AtomicInteger();
     }
 
     protected boolean isSiteStable() {
@@ -174,4 +173,18 @@ public int getOrder() {
         return LOWEST_PRECEDENCE;
     }
 
+    @Autowired
+    public void setCollector(DefaultDelayPingActionCollector collector) {
+        this.collector = collector;
+    }
+
+    @Autowired
+    public void setMetaCache(MetaCache metaCache) {
+        this.metaCache = metaCache;
+    }
+
+    @Autowired
+    public void setConfig(CheckerConfig config) {
+        this.config = config;
+    }
 }