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

Deprecated.

Certiorem will be removed in Rome 2.

@Deprecated
public class ThreadPoolNotifier
extends AbstractNotifier

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

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 java.util.concurrent.ThreadPoolExecutor	exeuctor Deprecated.
private java.util.concurrent.ConcurrentSkipListSet<java.lang.String>	pendings Deprecated.
private java.util.Timer	timer Deprecated.
private static long	TWO_MINUTES Deprecated.

Constructor Summary

Constructors

Modifier	Constructor and Description
	ThreadPoolNotifier() Deprecated.
	ThreadPoolNotifier(int startPoolSize, int maxPoolSize, int queueSize) Deprecated.
protected	ThreadPoolNotifier(java.util.concurrent.ThreadPoolExecutor executor) Deprecated.

Method Summary

Modifier and Type	Method and Description
protected void	enqueueNotification(Notification not) Deprecated. Enqueues a notification to run.
protected void	retry(Notification not) Deprecated. 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

TWO_MINUTES

private static final long TWO_MINUTES

Deprecated.

See Also:

Constant Field Values

exeuctor

protected final java.util.concurrent.ThreadPoolExecutor exeuctor

Deprecated.

timer

private final java.util.Timer timer

Deprecated.

pendings

private final java.util.concurrent.ConcurrentSkipListSet<java.lang.String> pendings

Deprecated.

Constructor Detail

ThreadPoolNotifier

public ThreadPoolNotifier()

Deprecated.

ThreadPoolNotifier

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

Deprecated.

ThreadPoolNotifier

protected ThreadPoolNotifier(java.util.concurrent.ThreadPoolExecutor executor)

Deprecated.

Method Detail

enqueueNotification

protected void enqueueNotification(Notification not)

Deprecated.

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)

Deprecated.

Schedules a notification to retry in two minutes.

Parameters:

not - Notification to retry