public class ThreadPoolNotifier extends AbstractNotifier
Notifier.SubscriptionSummaryCallback
Modifier and Type | Field and Description |
---|---|
protected ThreadPoolExecutor |
exeuctor |
Modifier | Constructor and Description |
---|---|
|
ThreadPoolNotifier() |
|
ThreadPoolNotifier(int startPoolSize,
int maxPoolSize,
int queueSize) |
protected |
ThreadPoolNotifier(ThreadPoolExecutor executor) |
Modifier and Type | Method and Description |
---|---|
protected void |
enqueueNotification(Notification not)
Enqueues a notification to run.
|
protected void |
retry(Notification not)
Schedules a notification to retry in two minutes.
|
notifySubscribers, postNotification
protected final ThreadPoolExecutor exeuctor
public ThreadPoolNotifier()
public ThreadPoolNotifier(int startPoolSize, int maxPoolSize, int queueSize)
protected ThreadPoolNotifier(ThreadPoolExecutor executor)
protected void enqueueNotification(Notification not)
enqueueNotification
in class AbstractNotifier
not
- protected void retry(Notification not)
not
- Notification to retryCopyright © 2017. All rights reserved.