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

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

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

revision 396 by torben, Tue Oct 6 04:59:03 2009 UTC revision 424 by torben, Thu Oct 8 20:39:39 2009 UTC
# Line 2  package dk.thoerup.curcuitbreaker; Line 2  package dk.thoerup.curcuitbreaker;
2    
3  import java.util.logging.Logger;  import java.util.logging.Logger;
4    
5    import dk.thoerup.curcuitbreaker.notification.Notifier;
6    import dk.thoerup.curcuitbreaker.notification.NullNotifier;
7    
8  /* Simple CircuitBreaker implementation - snipped from http://www.jroller.com/kenwdelong/entry/circuit_breaker_in_java  /* Simple CircuitBreaker implementation - snipped from http://www.jroller.com/kenwdelong/entry/circuit_breaker_in_java
9   *   *
10   *  example of how it can be used   *  example of how it can be used
# Line 45  public class CircuitBreaker{ Line 48  public class CircuitBreaker{
48                    
49          private CircuitBreakerState currentState;          private CircuitBreakerState currentState;
50                    
51          private OpenState open = new OpenState();          private final OpenState open = new OpenState();
52          private HalfOpenState halfOpen = new HalfOpenState();          private final HalfOpenState halfOpen = new HalfOpenState();
53          private ClosedState closed = new ClosedState();          private final ClosedState closed = new ClosedState();
54                    
55          private String name;          private String name;
56                    
57            private Notifier notifier = new NullNotifier();
58            
59          public CircuitBreaker(String name, int threshold, long timeoutMS) {          public CircuitBreaker(String name, int threshold, long timeoutMS) {
60                  closed.setThreshold(threshold);                  closed.setThreshold(threshold);
61                  open.setTimeout(timeoutMS);                  open.setTimeout(timeoutMS);
# Line 82  public class CircuitBreaker{ Line 87  public class CircuitBreaker{
87          synchronized(this) {          synchronized(this) {
88                  open.trip();                  open.trip();
89                  currentState = open;                  currentState = open;
   
90                                    
91                  logger.warning("Circuitbreaker tripBreaker - " + name);                  notifier.sendNotification(name, Notifier.Event.BreakerTripped);
92          }          }    
       
93      }      }
94            
95      public void attemptReset() {      public void attemptReset() {
96          synchronized(this) {          synchronized(this) {
97                  currentState = halfOpen;                  currentState = halfOpen;
98                                    notifier.sendNotification(name, Notifier.Event.BreakerAttemptReset);
                 logger.warning("Circuitbreaker attemptReset - " + name);  
99          }          }
100            
101      }      }
102            
103      public void reset() {      public void reset() {
104          synchronized(this) {          synchronized(this) {
105                  currentState = closed;                  currentState = closed;
106                                    notifier.sendNotification(name, Notifier.Event.BreakerReset);
                 logger.warning("Circuitbreaker reset - " + name);  
107          }          }
108      }      }
109            
110        
111      private CircuitBreakerState getState() {      private CircuitBreakerState getState() {
112          synchronized(this) {          synchronized(this) {
113                  return currentState;                  return currentState;
114          }          }
115      }      }
116        
117        public String getName() {
118            return name;
119        }
120        
121        public String getStateName() {
122            return getState().getName();
123        }
124        
125        public int getThreshold() {
126            return closed.getThreshold();
127        }
128        
129        public int getTimeout() {
130            return (int)open.getTimeout();
131        }
132        
133        public int getFailureCount() {
134            if (getState() == closed) {
135                    return closed.getFailureCount();
136            } else {
137                    return -1;
138            }
139        }
140        
141        public long getElapsed() {
142            if (getState() == open) {
143                    return open.getElapsed();
144            } else {
145                    return -1;
146            }
147        }
148        
149        public void setNotifier(Notifier notifier) {
150            this.notifier = notifier;
151        }
152        
153        public String getNotifierName() {
154            return notifier.getClass().getName();
155        }
156    
157  }  }
Legend:
Removed from v.396  
changed lines
  Added in v.424
  ViewVC Help
Powered by ViewVC 1.1.20