thoerup/circuitbreaker/LoggingCircuitBreaker.java

package dk.thoerup.circuitbreaker;

import java.util.*;
import dk.thoerup.circuitbreaker.notification.*;

public class LoggingCircuitBreaker extends AccountingCircuitBreaker {

        private LinkedList<LogEntry> log = new LinkedList<LogEntry>();

        final int maxSize = 50;

        public class LogEntry {
                public long time;
                public Notifier.Event event;            
        
                public LogEntry(Notifier.Event evnt) {
                        this.event = evnt;
                        this.time = System.currentTimeMillis();
                }
        }
        
        

        public LoggingCircuitBreaker(String name, int threshold, long timeoutMS) {
                super(name, threshold, timeoutMS);

        }

        @Override
        public void tripBreaker() {
                super.tripBreaker();
                addEntry(Notifier.Event.BreakerTripped);
        }
        
        @Override
        public void retripBreaker() {
                super.retripBreaker();
                addEntry(Notifier.Event.BreakerRetripped);
        }

        @Override
        public void reset() {
                super.reset();
                addEntry(Notifier.Event.BreakerReset);
        }

        private void addEntry(Notifier.Event event) {
                synchronized(this) {
                        log.addFirst( new LogEntry(event) );
                        if(log.size() > maxSize) {
                                log.removeLast();
                        }
                }
        }

        public LinkedList<LogEntry> getLog() {
                synchronized(this) {
                        return new LinkedList<LogEntry>(log); //return a copy so caller can to whatever he wants, when he wants
                }
        }
        
}
1	torben	1285	package dk.thoerup.circuitbreaker;
2
3			import java.util.*;
4			import dk.thoerup.circuitbreaker.notification.*;
5
6			public class LoggingCircuitBreaker extends AccountingCircuitBreaker {
7
8			private LinkedList<LogEntry> log = new LinkedList<LogEntry>();
9
10			final int maxSize = 50;
11
12			public class LogEntry {
13			public long time;
14			public Notifier.Event event;
15
16			public LogEntry(Notifier.Event evnt) {
17			this.event = evnt;
18			this.time = System.currentTimeMillis();
19			}
20			}
21
22
23
24			public LoggingCircuitBreaker(String name, int threshold, long timeoutMS) {
25			super(name, threshold, timeoutMS);
26
27			}
28
29			@Override
30			public void tripBreaker() {
31			super.tripBreaker();
32			addEntry(Notifier.Event.BreakerTripped);
33			}
34
35			@Override
36			public void retripBreaker() {
37			super.retripBreaker();
38			addEntry(Notifier.Event.BreakerRetripped);
39			}
40
41			@Override
42			public void reset() {
43			super.reset();
44			addEntry(Notifier.Event.BreakerReset);
45			}
46
47			private void addEntry(Notifier.Event event) {
48			synchronized(this) {
49			log.addFirst( new LogEntry(event) );
50			if(log.size() > maxSize) {
51			log.removeLast();
52			}
53			}
54			}
55
56			public LinkedList<LogEntry> getLog() {
57			synchronized(this) {
58			return new LinkedList<LogEntry>(log); //return a copy so caller can to whatever he wants, when he wants
59			}
60			}
61
62			}