/[projects]/miscJava/CircuitBreaker/src/main/java/dk/thoerup/circuitbreaker/notification/AsyncNotifier.java
ViewVC logotype

Diff of /miscJava/CircuitBreaker/src/main/java/dk/thoerup/circuitbreaker/notification/AsyncNotifier.java

Parent Directory Parent Directory | Revision Log Revision Log | View Patch Patch

revision 3211 by torben, Tue Jun 9 08:55:10 2015 UTC revision 3212 by torben, Thu Dec 28 09:34:47 2017 UTC
# Line 8  import dk.thoerup.circuitbreaker.Event; Line 8  import dk.thoerup.circuitbreaker.Event;
8  public abstract class AsyncNotifier implements Notifier {  public abstract class AsyncNotifier implements Notifier {
9                    
10    
11          public final void sendNotification(CircuitBreaker breaker, Event evnt) {          public final void sendNotification(CircuitBreaker<?> breaker, Event evnt) {
12                  ExecutorService exec = breaker.getExecutor();                    ExecutorService exec = breaker.getExecutor();  
13                                    
14                  exec.submit( new AsyncRunnable(breaker, evnt) );                  exec.submit( new AsyncRunnable(breaker, evnt) );
15          }          }
16                    
17          public abstract void sendAsync(CircuitBreaker breaker, Event evnt);          public abstract void sendAsync(CircuitBreaker<?> breaker, Event evnt);
18                    
19          public class AsyncRunnable implements Runnable {          public class AsyncRunnable implements Runnable {
20                  CircuitBreaker breaker;                  CircuitBreaker<?> breaker;
21                  Event evnt;                  Event evnt;
22                                    
23                  public AsyncRunnable(CircuitBreaker breaker, Event evnt) {                  public AsyncRunnable(CircuitBreaker<?> breaker, Event evnt) {
24                          this.breaker = breaker;                          this.breaker = breaker;
25                          this.evnt = evnt;                          this.evnt = evnt;
26                  }                  }
Legend:
Removed from v.3211  
changed lines
  Added in v.3212
  ViewVC Help
Powered by ViewVC 1.1.20