--- miscJava/CircuitBreaker/src/main/java/dk/thoerup/circuitbreaker/OpenState.java 2017/09/18 18:06:48 3211 +++ miscJava/CircuitBreaker/src/main/java/dk/thoerup/circuitbreaker/OpenState.java 2017/12/28 09:34:47 3212 @@ -5,6 +5,7 @@ import dk.thoerup.circuitbreaker.config.BreakerConfig; + public final class OpenState implements CircuitBreakerState { final private AtomicLong tripTime = new AtomicLong(0); @@ -15,7 +16,8 @@ this.config = config; } - public void preInvoke(CircuitBreaker circuitBreaker) throws Exception + + public void preInvoke(CircuitBreaker circuitBreaker) throws Exception { long now = System.currentTimeMillis(); long elapsed = now - tripTime.get(); @@ -30,12 +32,12 @@ } } - public void postInvoke(CircuitBreaker circuitBreaker) throws Exception + public void postInvoke(CircuitBreaker circuitBreaker) throws Exception { // NO OP } - public void onError(CircuitBreaker circuitBreaker, Exception t) throws Exception + public void onError(CircuitBreaker circuitBreaker, Exception t) throws Exception { // NO OP }