thoerup/circuitbreaker/CircuitBreakerManager.java

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();
                }               
        }
        
}
1	package dk.thoerup.circuitbreaker;
2
3	import java.util.Iterator;
4	import java.util.Map;
5	import java.util.Set;
6	import java.util.concurrent.ConcurrentHashMap;
7
8	public class CircuitBreakerManager {
9
10	private static CircuitBreakerManager manager = null;
11
12	private Map<String,CircuitBreaker> breakers = new ConcurrentHashMap<String,CircuitBreaker>();
13
14	private CircuitBreakerManager() {
15	}
16
17
18	public static CircuitBreakerManager getManager() { //singleton interface
19	synchronized(CircuitBreakerManager.class) {
20	if (manager == null) {
21	manager = new CircuitBreakerManager();
22	}
23	}
24	return manager;
25	}
26
27	public Set<String> getCircuitBreakerNames() {
28	return breakers.keySet();
29	}
30
31	public CircuitBreaker getCircuitBreaker(String name) {
32	return breakers.get(name);
33	}
34
35	public void removeCircuitBreaker(String name) {
36	breakers.remove(name);
37	}
38
39	public void addCircuitBreaker(CircuitBreaker cb) {
40	breakers.put(cb.getName(), cb);
41	}
42
43	public void shutdown() {
44	for (Iterator<String> it = breakers.keySet().iterator(); it.hasNext(); ) {
45	String key = it.next();
46	breakers.get(key).shutdown();
47	it.remove();
48	}
49	}
50
51	}