--- CircuitBreaker/src/dk/thoerup/curcuitbreaker/AccountingCircuitBreaker.java 2009/10/20 10:26:50 450 +++ CircuitBreaker/src/dk/thoerup/circuitbreaker/AccountingCircuitBreaker.java 2010/03/08 09:46:10 624 @@ -1,6 +1,7 @@ -package dk.thoerup.curcuitbreaker; +package dk.thoerup.circuitbreaker; import java.util.concurrent.atomic.AtomicInteger; +import java.util.concurrent.atomic.AtomicLong; public class AccountingCircuitBreaker extends CircuitBreaker { @@ -9,6 +10,10 @@ private AtomicInteger totalFailureCount = new AtomicInteger(0); //how many times has the backend thrown an exception private AtomicInteger totalCallCount = new AtomicInteger(0); + private AtomicLong lastTrip = new AtomicLong(0); + private AtomicLong lastFailure = new AtomicLong(0); + private AtomicLong lastReset = new AtomicLong(0); + private long lastResetCounters = 0; public AccountingCircuitBreaker(String name, int threshold, long timeoutMS) { @@ -28,6 +33,7 @@ blockCount.incrementAndGet(); } else { totalFailureCount.incrementAndGet(); + lastFailure.set( System.currentTimeMillis() ); } throw e; } @@ -39,8 +45,17 @@ public void tripBreaker() { super.tripBreaker(); tripCount.incrementAndGet(); + lastTrip.set( System.currentTimeMillis() ); } + + + @Override + public void reset() { + super.reset(); + lastReset.set( System.currentTimeMillis()); + } + public int getTripCount() { return tripCount.get(); } @@ -57,6 +72,18 @@ return lastResetCounters; } + public long getLastTrip() { + return lastTrip.get(); + } + + public long getLastFailure() { + return lastFailure.get(); + } + + public long getLastReset() { + return lastReset.get(); + } + public int getTotalCallCount() { return totalCallCount.get(); } @@ -66,6 +93,9 @@ blockCount.set(0); totalFailureCount.set(0); totalCallCount.set(0); + lastTrip.set(0); + lastReset.set(0); + lastFailure.set(0); lastResetCounters = System.currentTimeMillis(); }