Added demo app

Author: guyplusplus

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

@@ -0,0 +1,87 @@
+package com.geckotechnology.simpleCircuitBreaker;
+
+import java.io.File;
+import java.io.FileInputStream;
+import java.io.IOException;
+import java.io.InputStream;
+import java.util.Date;
+import java.util.Properties;
+import java.util.Random;
+import java.util.Timer;
+import java.util.TimerTask;
+import java.util.concurrent.atomic.AtomicInteger;
+
+import org.junit.Test;
+
+public class DemoApp {
+	
+	private static final Random rd = new Random(System.currentTimeMillis());
+	private static final int NB_THREADS = 5;
+	private static final float ACTUAL_FAILURE_RATIO = 70;
+	private static final long WAIT_BETWEEN_LOOP_MS = 500;
+
+	private CircuitBreaker circuitBreaker;
+
+	public static void main(String[] args) {
+		new Thread() {
+			@Override
+			public void run() {
+				new DemoApp().test();				
+			}
+		}.start();
+	}
+	
+	private void loadConfigFile() {
+		try {
+			Properties props = new Properties();
+			InputStream is = CircuitBreakerConfigTest.class.getResourceAsStream("/demo.config");
+			props.load(is);
+			is.close();
+			CircuitBreakerConfig config = new CircuitBreakerConfig(props);
+			System.out.println("config:{" + config.toString() + "}");
+			circuitBreaker = new CircuitBreaker(config);
+		} catch (Exception e) {
+			e.printStackTrace();
+			System.exit(-1);
+		}
+		circuitBreaker.getBreakerStateEventManager().addBreakerStateEventListener(new BreakerStateEventListener() {
+			@Override
+			public void onCircuitBreakerStateChangeEvent(CircuitBreakerStateChangeEvent event) {
+				System.out.println("CircuitBreaker state changed. " + event);
+			}
+		});
+	}
+	
+	public void test() {
+		loadConfigFile();
+		for(int i = 0; i<NB_THREADS; i++) {
+			final AtomicInteger threadId = new AtomicInteger(i);
+			new Thread() {
+				@Override
+				public void run() {
+					while(true) {	
+						if(circuitBreaker.isClosedForThisCall()) {
+							boolean willFail = (rd.nextInt(1000) > 10 * ACTUAL_FAILURE_RATIO);
+							long duration = rd.nextInt(1500); 
+							if(willFail) {
+								System.out.println("[" + threadId.get() + "] Breaker is closed. Simulating callFailed with duration: " + duration);
+								TestUtils.sleep(duration);
+								circuitBreaker.callFailed(duration);
+							}
+							else {
+								System.out.println("[" + threadId.get() + "] Breaker is closed. Simulating callSucceeded with duration: " + duration);
+								TestUtils.sleep(duration);
+								circuitBreaker.callSucceeded(duration);
+							}					
+						}
+						else {
+							System.out.println("[" + threadId.get() + "] Breaker is opened. Pass...");
+						}
+						TestUtils.sleep(WAIT_BETWEEN_LOOP_MS);
+					}
+				}
+			}.start();
+		}
+	}
+
+}

src/test/resources/demo.config

@@ -0,0 +1,9 @@
+name=demo
+slidingWindowSize=30
+permittedNumberOfCallsInHalfOpenState=5
+slowCallDurationThreshold=528
+minimumNumberOfCalls=20
+failureRateThreshold=75.1
+slowCallRateThreshold=45
+waitDurationInOpenState=2000
+maxDurationOpenInHalfOpenState=1100