added in test code check sum of closed state

Author: guyplusplus

src/main/java/com/geckotechnology/simpleCircuitBreaker/BreakerClosedState.java

@@ -99,9 +99,10 @@ private void clearBucket(int timeInSec) {
     }
 
     /**
-     * Method used during development to validate array and sum are correctly aligned
+     * Method used during unit test to validate array and sum are correctly aligned. If not, code exists
+     * Method is not synchronized
      */
-    private void testCheckSum() {
+    void testCheckSumForUnitTest() {
         int checkCallCount = 0;
         int checkFailureCallCount = 0;
         int checkSlowCallDurationCount = 0;

src/main/java/com/geckotechnology/simpleCircuitBreaker/CircuitBreaker.java

@@ -35,6 +35,14 @@ CircuitBreakerConfig getCircuitBreakerConfig() {
     	return circuitBreakerConfig;
     }
 
+    /**
+     * Used for unit test. Method is not synchronized
+     * @return current state object of the breaker
+     */
+    BreakerStateInterface getBreakerState() {
+    	return breakerState;
+    }
+    
     void moveToClosedState() {
     	breakerState = new BreakerClosedState(this);
     	logger.info("Breaker state changed to: CLOSED");

src/test/java/com/geckotechnology/simpleCircuitBreaker/Test2.java

@@ -79,6 +79,12 @@ public void test(String propsPrefix, String configPath) {
 				@Override
 				public void run() {
 					while(true) {
+						synchronized (circuitBreaker) {
+							BreakerStateInterface breakerState = circuitBreaker.getBreakerState();
+							if(breakerState instanceof BreakerClosedState) {
+								((BreakerClosedState) breakerState).testCheckSumForUnitTest();
+							}
+						}
 						if(circuitBreaker.isClosedForThisCall()) {
 							boolean willFail = (rd.nextInt(1000) > 700);
 							if(willFail) {