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