circuitbreaker/notification/AsyncNotifier.java

package dk.thoerup.circuitbreaker.notification;

import java.util.concurrent.ExecutorService;

import dk.thoerup.circuitbreaker.CircuitBreaker;

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
7	public abstract class AsyncNotifier implements Notifier {
8
9
10	public final void sendNotification(CircuitBreaker breaker, Event evnt) {
11	ExecutorService exec = breaker.getExecutor();
12
13	exec.submit( new AsyncRunnable(breaker, evnt) );
14	}
15
16	public abstract void sendAsync(CircuitBreaker breaker, Event evnt);
17
18	public class AsyncRunnable implements Runnable {
19	CircuitBreaker breaker;
20	Event evnt;
21
22	public AsyncRunnable(CircuitBreaker breaker, Event evnt) {
23	this.breaker = breaker;
24	this.evnt = evnt;
25	}
26
27
28	public void run() {
29	sendAsync(breaker, evnt);
30	}
31
32
33	}
34
35	}