Skip to content

Commit b5981cc

Browse files
committed
Fix the issue of instance-level circuit breaker failure
1 parent 69e55eb commit b5981cc

File tree

1 file changed

+7
-1
lines changed
  • joylive-implement/joylive-flowcontrol/joylive-flowcontrol-resilience4j/src/main/java/com/jd/live/agent/implement/flowcontrol/circuitbreak/resilience4j

1 file changed

+7
-1
lines changed

joylive-implement/joylive-flowcontrol/joylive-flowcontrol-resilience4j/src/main/java/com/jd/live/agent/implement/flowcontrol/circuitbreak/resilience4j/Resilience4jCircuitBreaker.java

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -229,10 +229,16 @@ private class InstanceStateListener extends ServiceStateListener implements Auto
229229
this.instanceId = instanceId;
230230
}
231231

232+
@Override
233+
protected void onOpen(long now) {
234+
super.onOpen(now);
235+
policy.addInspector(instanceId, Resilience4jCircuitBreaker.this);
236+
}
237+
232238
@Override
233239
protected void onClose(long now) {
234240
super.onClose(now);
235-
policy.addInspector(instanceId, Resilience4jCircuitBreaker.this);
241+
policy.removeInspector(instanceId, Resilience4jCircuitBreaker.this);
236242
}
237243

238244
@Override

0 commit comments

Comments
 (0)