com.hp.util.observer

Class SingleThreadListenerHandler<T>

java.lang.Object

com.hp.util.observer.AbstractListenerHandler<T>

com.hp.util.observer.SingleThreadListenerHandler<T>

Type Parameters:

T - type of the listener.

All Implemented Interfaces:

ListenerHandler<T>, Observable<T>

public class SingleThreadListenerHandler<T>
extends AbstractListenerHandler<T>

Listeners are notified in the same thread where the notification started.

At the time when an event takes place a snapshot of the registered listeners is taken and those listeners are notified regardless if they are unregistered before they are actually notified of that particular event.

This listener handler is recommended when the notification rate is high and listeners do not spend too much time processing the notification.

Author:

Fabiel Zuniga

Constructor Summary

Constructors

Constructor and Description
SingleThreadListenerHandler(Store<T> listenerStore, ErrorHandler<T,Exception> errorHandler) Creates a new listener handler.
SingleThreadListenerHandler(Store<T> listenerStore, ErrorHandler<T,Exception> errorHandler, boolean stopOnError) Creates a new listener handler.

Method Summary

Methods

Modifier and Type	Method and Description
protected void	executeCallback(T listener, Invoker<T> invoker) Executes a call back method to notify the listener.
protected void	notify(Collection<T> listenersToNotify, Invoker<T> invoker) Notifies listeners.

Methods inherited from class com.hp.util.observer.AbstractListenerHandler

errorOccurred, notifyListeners, register, unregister

Methods inherited from class java.lang.Object

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

Constructor Detail

SingleThreadListenerHandler

public SingleThreadListenerHandler(Store<T> listenerStore,
                           ErrorHandler<T,Exception> errorHandler)

Creates a new listener handler.

Parameters:

listenerStore - listener store.

errorHandler - error handler used to delegate error handling when notifying a listener.

SingleThreadListenerHandler

public SingleThreadListenerHandler(Store<T> listenerStore,
                           ErrorHandler<T,Exception> errorHandler,
                           boolean stopOnError)

Creates a new listener handler.

Parameters:

listenerStore - listener store.

errorHandler - error handler used to delegate error handling when notifying a listener.

stopOnError - boolean to define stop on error behavior.

Method Detail

executeCallback

protected void executeCallback(T listener,
                   Invoker<T> invoker)

Description copied from class: AbstractListenerHandler

Executes a call back method to notify the listener.

Specified by:

executeCallback in class AbstractListenerHandler<T>

Parameters:

listener - Listener to notify.

invoker - Invoker to use.

notify

protected void notify(Collection<T> listenersToNotify,
          Invoker<T> invoker)

Notifies listeners.

Overrides:

notify in class AbstractListenerHandler<T>

Parameters:

listenersToNotify - listeners to notify.

invoker - invoker to use.