/[projects]/miscJava/CircuitBreaker/src/main/java/dk/thoerup/circuitbreaker/CircuitBreakerManager.java
ViewVC logotype

Diff of /miscJava/CircuitBreaker/src/main/java/dk/thoerup/circuitbreaker/CircuitBreakerManager.java

Parent Directory Parent Directory | Revision Log Revision Log | View Patch Patch

revision 3211 by torben, Tue Jun 9 09:28:14 2015 UTC revision 3212 by torben, Thu Dec 28 09:34:47 2017 UTC
# Line 9  public class CircuitBreakerManager { Line 9  public class CircuitBreakerManager {
9                    
10          private static CircuitBreakerManager manager = null;          private static CircuitBreakerManager manager = null;
11                    
12          private Map<String,CircuitBreaker> breakers = new ConcurrentHashMap<String,CircuitBreaker>();          private Map<String,CircuitBreaker<?>> breakers = new ConcurrentHashMap<>();
13                    
14          private CircuitBreakerManager() {          private CircuitBreakerManager() {
15          }          }
# Line 28  public class CircuitBreakerManager { Line 28  public class CircuitBreakerManager {
28                  return breakers.keySet();                  return breakers.keySet();
29          }          }
30                    
31          public CircuitBreaker getCircuitBreaker(String name) {          public CircuitBreaker<?> getCircuitBreaker(String name) {
32                  return breakers.get(name);                  return breakers.get(name);
33          }          }
34    
# Line 36  public class CircuitBreakerManager { Line 36  public class CircuitBreakerManager {
36                  breakers.remove(name);                  breakers.remove(name);
37          }          }
38                    
39          public void addCircuitBreaker(CircuitBreaker cb) {          public void addCircuitBreaker(CircuitBreaker<?> cb) {
40                  breakers.put(cb.getName(), cb);                  breakers.put(cb.getName(), cb);
41          }          }
42                    
43          public void shutdown() {          public void shutdown() {
44                                    
45                  for ( Entry<String,CircuitBreaker> entry : breakers.entrySet() )  {                  for ( Entry<String,CircuitBreaker<?>> entry : breakers.entrySet() )  {
46                          entry.getValue().shutdown();                          entry.getValue().shutdown();
47                  }                                }              
48                  breakers.clear();                  breakers.clear();
Legend:
Removed from v.3211  
changed lines
  Added in v.3212
  ViewVC Help
Powered by ViewVC 1.1.20