circuitbreaker/notification/AsyncNotifier.java

package dk.thoerup.circuitbreaker.notification;

import java.util.concurrent.ExecutorService;

import dk.thoerup.circuitbreaker.CircuitBreaker;
import dk.thoerup.circuitbreaker.Event;

public abstract class AsyncNotifier implements Notifier {
        

        public final void sendNotification(CircuitBreaker<?> breaker, Event evnt) {
                ExecutorService exec = breaker.getExecutor();   
                
                exec.submit( new AsyncRunnable(breaker, evnt) );
        }
        
        public abstract void sendAsync(CircuitBreaker<?> breaker, Event evnt);
        
        public class AsyncRunnable implements Runnable {
                CircuitBreaker<?> breaker;
                Event evnt;
                
                public AsyncRunnable(CircuitBreaker<?> breaker, Event evnt) {
                        this.breaker = breaker;
                        this.evnt = evnt;
                }
                
                
                public void run() {
                        sendAsync(breaker, evnt);
                }
                
                
        }

}
1	package dk.thoerup.circuitbreaker.notification;
2
3	import java.util.concurrent.ExecutorService;
4
5	import dk.thoerup.circuitbreaker.CircuitBreaker;
6	import dk.thoerup.circuitbreaker.Event;
7
8	public abstract class AsyncNotifier implements Notifier {
9
10
11	public final void sendNotification(CircuitBreaker<?> breaker, Event evnt) {
12	ExecutorService exec = breaker.getExecutor();
13
14	exec.submit( new AsyncRunnable(breaker, evnt) );
15	}
16
17	public abstract void sendAsync(CircuitBreaker<?> breaker, Event evnt);
18
19	public class AsyncRunnable implements Runnable {
20	CircuitBreaker<?> breaker;
21	Event evnt;
22
23	public AsyncRunnable(CircuitBreaker<?> breaker, Event evnt) {
24	this.breaker = breaker;
25	this.evnt = evnt;
26	}
27
28
29	public void run() {
30	sendAsync(breaker, evnt);
31	}
32
33
34	}
35
36	}