org.ametys.core.observation

Class ObservationManager

java.lang.Object

org.apache.avalon.framework.logger.AbstractLogEnabled

org.ametys.core.observation.ObservationManager

All Implemented Interfaces:

Disposable, Component, Contextualizable, LogEnabled, Serviceable

public class ObservationManager
extends AbstractLogEnabled
implements Component, Serviceable, Contextualizable, Disposable

Manager for dispatching Event instances to Observers.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
(package private) class	ObservationManager.AbstractAsyncObserve Runnable to be used for asynchronous calls
(package private) static class	ObservationManager.AsyncObserveThreadFactory Thread factory for async observers.
(package private) class	ObservationManager.NonParallelAsyncObserve Runnable for non parallel observers
(package private) class	ObservationManager.ParallelAsyncObserve Runnable for parallel observers

Field Summary

Fields

Modifier and Type	Field and Description
private static Logger	__ALL_EVENTS_LOGGER
private static ExecutorService	__PARALLEL_THREAD_EXECUTOR The executor service managing the thread pool of asynchronous observers allowed to run in parallel.
private static ExecutorService	__SINGLE_THREAD_EXECUTOR The executor service managing the single thread pool.
protected Context	_context Cocoon context
protected ServiceManager	_manager Service manager
private ObserverExtensionPoint	_observerExtPt
private Collection<Observer>	_registeredObservers
static String	ROLE Avalon ROLE.

Constructor Summary

Constructors

Constructor and Description
ObservationManager()

Method Summary

Modifier and Type	Method and Description
private void	_asyncObserve(Collection<AsyncObserver> parallelObservers, List<AsyncObserver> nonParallelObservers, Event event, Map<String,Object> transientVars, List<Future> result) Async observe through a thread pool
protected void	_observesEvent(Event event, List<Observer> supportedObservers, List<Future> result) Observes the event
void	contextualize(Context context)
void	dispose()
List<Future>	notify(Event event) Notify of a event which will be dispatch to registered observers.
void	registerObserver(Observer observer) Registers an Observer.
void	service(ServiceManager manager)
void	unregisterObserver(Observer observer) Unregisters an Observer.

Methods inherited from class org.apache.avalon.framework.logger.AbstractLogEnabled

enableLogging, getLogger, setupLogger, setupLogger, setupLogger

Methods inherited from class java.lang.Object

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

Field Detail

ROLE

public static final String ROLE

Avalon ROLE.

__ALL_EVENTS_LOGGER

private static final Logger __ALL_EVENTS_LOGGER

__SINGLE_THREAD_EXECUTOR

private static ExecutorService __SINGLE_THREAD_EXECUTOR

The executor service managing the single thread pool. This threads is used to run non-parallelizable observers.

__PARALLEL_THREAD_EXECUTOR

private static ExecutorService __PARALLEL_THREAD_EXECUTOR

The executor service managing the thread pool of asynchronous observers allowed to run in parallel.

_context

protected Context _context

Cocoon context

_manager

protected ServiceManager _manager

Service manager

_observerExtPt

private ObserverExtensionPoint _observerExtPt

_registeredObservers

private Collection<Observer> _registeredObservers

Constructor Detail

ObservationManager

public ObservationManager()

Method Detail

service

public void service(ServiceManager manager)
             throws ServiceException

Specified by:

service in interface Serviceable

Throws:

ServiceException

contextualize

public void contextualize(Context context)
                   throws ContextException

Specified by:

contextualize in interface Contextualizable

Throws:

ContextException

notify

public List<Future> notify(Event event)

Notify of a event which will be dispatch to registered observers.

Parameters:

event - the event to notify.

Returns:

The Future objects of the asynchronous observers

_observesEvent

protected void _observesEvent(Event event,
                              List<Observer> supportedObservers,
                              List<Future> result)
                       throws Exception

Observes the event

Parameters:

event - The event

supportedObservers - list of observers

result - The result object to fill

Throws:

Exception - on error

_asyncObserve

private void _asyncObserve(Collection<AsyncObserver> parallelObservers,
                           List<AsyncObserver> nonParallelObservers,
                           Event event,
                           Map<String,Object> transientVars,
                           List<Future> result)

Async observe through a thread pool

Parameters:

parallelObservers - parallelizable asynchronous observers

nonParallelObservers - non parallelizable asynchronous observers

event - The event to observe

transientVars - The observer transient vars

result - The future results

dispose

public void dispose()

Specified by:

dispose in interface Disposable

registerObserver

public void registerObserver(Observer observer)

Registers an Observer.

Parameters:

observer - the Observer.

unregisterObserver

public void unregisterObserver(Observer observer)

Unregisters an Observer.

Parameters:

observer - the Observer.