thoerup/curcuitbreaker/CircuitBreakerManager.java

package dk.thoerup.curcuitbreaker;

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 addCircuitBreaker(CircuitBreaker cb) {
                breakers.put(cb.getName(), cb);
        }
        
        
}
1	package dk.thoerup.curcuitbreaker;
2
3	import java.util.Map;
4	import java.util.Set;
5	import java.util.concurrent.ConcurrentHashMap;
6
7	public class CircuitBreakerManager {
8
9	private static CircuitBreakerManager manager = null;
10
11	private Map<String,CircuitBreaker> breakers = new ConcurrentHashMap<String,CircuitBreaker>();
12
13	private CircuitBreakerManager() {
14	}
15
16
17	public static CircuitBreakerManager getManager() { //singleton interface
18	if (manager == null) {
19	manager = new CircuitBreakerManager();
20	}
21	return manager;
22	}
23
24	public Set<String> getCircuitBreakerNames() {
25	return breakers.keySet();
26	}
27
28	public CircuitBreaker getCircuitBreaker(String name) {
29	return breakers.get(name);
30	}
31
32	public void addCircuitBreaker(CircuitBreaker cb) {
33	breakers.put(cb.getName(), cb);
34	}
35
36
37	}