io.pravega.client.stream.notifications.notifier

Class AbstractNotifier<T extends Notification>

java.lang.Object

io.pravega.client.stream.notifications.notifier.AbstractNotifier<T>

Type Parameters:

T - notification subtype

All Implemented Interfaces:

Observable<T>

Direct Known Subclasses:

AbstractPollingNotifier

public abstract class AbstractNotifier<T extends Notification>
extends java.lang.Object
implements Observable<T>

AbstractNotifier which is used by all types of Notifiers.

Field Summary

Fields

Modifier and Type	Field and Description
protected java.util.concurrent.ScheduledExecutorService	executor
protected NotificationSystem	notifySystem

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractNotifier(NotificationSystem notifySystem, java.util.concurrent.ScheduledExecutorService executor)

Method Summary

Modifier and Type	Method and Description
void	registerListener(Listener<T> listener) Register listener for notification type T.
void	unregisterAllListeners() Remove all listeners for a given type.
void	unregisterListener(Listener<T> listener) Remove a listener.

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.pravega.client.stream.notifications.Observable

getType

Field Detail

notifySystem

protected final NotificationSystem notifySystem

executor

protected final java.util.concurrent.ScheduledExecutorService executor

Constructor Detail

AbstractNotifier

protected AbstractNotifier(NotificationSystem notifySystem,
                           java.util.concurrent.ScheduledExecutorService executor)

Method Detail

unregisterListener

public void unregisterListener(Listener<T> listener)

Description copied from interface: Observable

Remove a listener.

Specified by:

unregisterListener in interface Observable<T extends Notification>

Parameters:

listener - the listener which needs to be removed.

unregisterAllListeners

public void unregisterAllListeners()

Description copied from interface: Observable

Remove all listeners for a given type.

Specified by:

unregisterAllListeners in interface Observable<T extends Notification>

registerListener

public void registerListener(Listener<T> listener)

Description copied from interface: Observable

Register listener for notification type T. Multiple listeners can be added for the same type.

Specified by:

registerListener in interface Observable<T extends Notification>

Parameters:

listener - This is the listener which will be invoked incase of an Notification.