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	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	}