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