com.rometools.certiorem.hub.notify.standard

Class ThreadPoolNotifier

java.lang.Object

com.rometools.certiorem.hub.notify.standard.AbstractNotifier

com.rometools.certiorem.hub.notify.standard.ThreadPoolNotifier

All Implemented Interfaces:

Notifier

public class ThreadPoolNotifier
extends AbstractNotifier

A notifier implementation that uses a thread pool to deliver notifications to subscribers

Author:

robert.cooper

Nested Class Summary

Nested classes/interfaces inherited from interface com.rometools.certiorem.hub.Notifier

Notifier.SubscriptionSummaryCallback

Field Summary

Fields

Modifier and Type	Field and Description
protected ThreadPoolExecutor	exeuctor

Constructor Summary

Constructors

Modifier	Constructor and Description
	ThreadPoolNotifier()
	ThreadPoolNotifier(int startPoolSize, int maxPoolSize, int queueSize)
protected	ThreadPoolNotifier(ThreadPoolExecutor executor)

Method Summary

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.

Methods inherited from class com.rometools.certiorem.hub.notify.standard.AbstractNotifier

notifySubscribers, postNotification

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

exeuctor

protected final ThreadPoolExecutor exeuctor

Constructor Detail

ThreadPoolNotifier

public ThreadPoolNotifier()

ThreadPoolNotifier

public ThreadPoolNotifier(int startPoolSize,
                          int maxPoolSize,
                          int queueSize)

ThreadPoolNotifier

protected ThreadPoolNotifier(ThreadPoolExecutor executor)

Method Detail

enqueueNotification

protected void enqueueNotification(Notification not)

Enqueues a notification to run. If the notification fails, it will be retried every two minutes until 5 attempts are completed. Notifications to the same callback should be delivered successfully in order.

Specified by:

enqueueNotification in class AbstractNotifier

Parameters:

not -

retry

protected void retry(Notification not)

Schedules a notification to retry in two minutes.

Parameters:

not - Notification to retry