--- CircuitBreaker/src/dk/thoerup/curcuitbreaker/OpenState.java 2009/10/06 05:22:40 397 +++ CircuitBreaker/src/dk/thoerup/circuitbreaker/OpenState.java 2009/10/22 06:01:35 467 @@ -1,18 +1,18 @@ -package dk.thoerup.curcuitbreaker; +package dk.thoerup.circuitbreaker; import java.util.concurrent.atomic.AtomicLong; -public class OpenState implements CircuitBreakerState { +public final class OpenState implements CircuitBreakerState { - private AtomicLong tripTime = new AtomicLong(0); - private AtomicLong timeout = new AtomicLong(0); + final private AtomicLong tripTime = new AtomicLong(0); + final private AtomicLong timeout = new AtomicLong(0); public void setTimeout(long timeout) { this.timeout.set( timeout ); } - public void preInvoke(CircuitBreaker circuitBreaker) throws Throwable + public void preInvoke(CircuitBreaker circuitBreaker) throws Exception { long now = System.currentTimeMillis(); long elapsed = now - tripTime.get(); @@ -27,12 +27,12 @@ } } - public void postInvoke(CircuitBreaker circuitBreaker) throws Throwable + public void postInvoke(CircuitBreaker circuitBreaker) throws Exception { // NO OP } - public void onError(CircuitBreaker circuitBreaker, Throwable t) throws Throwable + public void onError(CircuitBreaker circuitBreaker, Exception t) throws Exception { // NO OP }