thoerup/circuitbreaker/OpenState.java

package dk.thoerup.circuitbreaker;

import java.util.concurrent.atomic.AtomicLong;


public final class OpenState implements CircuitBreakerState {

        final private AtomicLong tripTime = new AtomicLong(0);
        final private AtomicLong timeout = new AtomicLong(0);
        
        public void setTimeout(long timeout) {
                this.timeout.set( timeout );
        }
        
    public void preInvoke(CircuitBreaker circuitBreaker) throws Exception
    {
        long now = System.currentTimeMillis();
        long elapsed = now - tripTime.get();
        
        if(elapsed > timeout.get())
        {
            circuitBreaker.attemptReset();
        }
        else
        {
            throw new CircuitBreakerException("Circuit Breaker is open; calls are failing fast");
        }
    }

    public void postInvoke(CircuitBreaker circuitBreaker) throws Exception
    {
        // NO OP
    }

    public void onError(CircuitBreaker circuitBreaker, Exception t) throws Exception
    {
        // NO OP
    }

    void trip()
    {
        long now = System.currentTimeMillis();
        tripTime.set(now);
    }

        public String getName() {
                return "Open";
        }
        
        public long getTimeout() {
                return timeout.get();
        }
        
        public long getElapsed() {
        long now = System.currentTimeMillis();
        long elapsed = now - tripTime.get();
        return elapsed;
        }

}
1	package dk.thoerup.circuitbreaker;
2
3	import java.util.concurrent.atomic.AtomicLong;
4
5
6	public final class OpenState implements CircuitBreakerState {
7
8	final private AtomicLong tripTime = new AtomicLong(0);
9	final private AtomicLong timeout = new AtomicLong(0);
10
11	public void setTimeout(long timeout) {
12	this.timeout.set( timeout );
13	}
14
15	public void preInvoke(CircuitBreaker circuitBreaker) throws Exception
16	{
17	long now = System.currentTimeMillis();
18	long elapsed = now - tripTime.get();
19
20	if(elapsed > timeout.get())
21	{
22	circuitBreaker.attemptReset();
23	}
24	else
25	{
26	throw new CircuitBreakerException("Circuit Breaker is open; calls are failing fast");
27	}
28	}
29
30	public void postInvoke(CircuitBreaker circuitBreaker) throws Exception
31	{
32	// NO OP
33	}
34
35	public void onError(CircuitBreaker circuitBreaker, Exception t) throws Exception
36	{
37	// NO OP
38	}
39
40	void trip()
41	{
42	long now = System.currentTimeMillis();
43	tripTime.set(now);
44	}
45
46	public String getName() {
47	return "Open";
48	}
49
50	public long getTimeout() {
51	return timeout.get();
52	}
53
54	public long getElapsed() {
55	long now = System.currentTimeMillis();
56	long elapsed = now - tripTime.get();
57	return elapsed;
58	}
59
60	}