package dk.thoerup.circuitbreaker;

import java.util.Iterator;
import java.util.Map;
import java.util.Set;
import java.util.concurrent.ConcurrentHashMap;

public class CircuitBreakerManager {
	
	private static CircuitBreakerManager manager = null;
	
	private Map<String,CircuitBreaker> breakers = new ConcurrentHashMap<String,CircuitBreaker>();
	
	private CircuitBreakerManager() {
	}
	
	
	public static CircuitBreakerManager getManager() { //singleton interface
		synchronized(CircuitBreakerManager.class) {
			if (manager == null) {
				manager = new CircuitBreakerManager();
			}
		}
		return manager;
	}
	
	public Set<String> getCircuitBreakerNames() {
		return breakers.keySet();
	}
	
	public CircuitBreaker getCircuitBreaker(String name) {
		return breakers.get(name);
	}

	public void removeCircuitBreaker(String name) {
		breakers.remove(name);
	}
	
	public void addCircuitBreaker(CircuitBreaker cb) {
		breakers.put(cb.getName(), cb);
	}
	
	public void shutdown() {
		for (Iterator<String> it = breakers.keySet().iterator(); it.hasNext(); )  {
			String key = it.next();
			breakers.get(key).shutdown();
			it.remove();
		}		
	}
	
}