ch.algotrader.event

Class EventListenerRegistryImpl

java.lang.Object

ch.algotrader.event.EventListenerRegistryImpl

All Implemented Interfaces:

EventBroadcaster, EventListenerRegistry

public final class EventListenerRegistryImpl
extends java.lang.Object
implements EventListenerRegistry

Default EventListenerRegistry implementations. Instances of this class are expected to be thread-safe.

Constructor Summary

Constructors

Constructor and Description
EventListenerRegistryImpl(ThreadPoolTaskExecutor executor, CommonConfig config)

Method Summary

Modifier and Type	Method and Description
java.util.concurrent.Future<java.lang.Void>	broadcast(java.lang.Object event) Listeners for the event are executed in parallel.
void	broadcastInSameThread(java.lang.Object event) Listeners of the event are executed in the caller's thread
java.util.Set<EventListener<?>>	getListeners(java.lang.Class<?> eventType) Returns listeners registered for the given event type.
<T> void	register(EventListener<T> listener, java.lang.Class<T> eventType) Registers the given event listener as a sink for the given type of events.
void	shutdown() Waits for queued events to be processed and then shuts down
<T> void	unregister(EventListener<T> listener, java.lang.Class<T> eventType) Unregisters the given event listener as a sink for the given type of events.

Methods inherited from class java.lang.Object

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

Constructor Detail

EventListenerRegistryImpl

public EventListenerRegistryImpl(ThreadPoolTaskExecutor executor,
                                 CommonConfig config)

Method Detail

register

public <T> void register(EventListener<T> listener,
                         java.lang.Class<T> eventType)

Description copied from interface: EventListenerRegistry

Registers the given event listener as a sink for the given type of events.

Specified by:

register in interface EventListenerRegistry

Type Parameters:

T - event type

Parameters:

listener - event listener

eventType - event class

unregister

public <T> void unregister(EventListener<T> listener,
                           java.lang.Class<T> eventType)

Description copied from interface: EventListenerRegistry

Unregisters the given event listener as a sink for the given type of events.

Specified by:

unregister in interface EventListenerRegistry

Type Parameters:

T - event type

Parameters:

listener - event listener

eventType - type to be unregistered from

getListeners

public java.util.Set<EventListener<?>> getListeners(java.lang.Class<?> eventType)

Description copied from interface: EventListenerRegistry

Returns listeners registered for the given event type.

Specified by:

getListeners in interface EventListenerRegistry

Parameters:

eventType - type to search for

broadcast

public java.util.concurrent.Future<java.lang.Void> broadcast(java.lang.Object event)

Description copied from interface: EventBroadcaster

Listeners for the event are executed in parallel. This method guarantees listeners of the event are executed in the way, that no listener proceeds with other event until they all have finished with the fist one.

Specified by:

broadcast in interface EventBroadcaster

Parameters:

event - - the event

Returns:

future representing the result of broadcasting

broadcastInSameThread

public void broadcastInSameThread(java.lang.Object event)

Description copied from interface: EventBroadcaster

Listeners of the event are executed in the caller's thread

Specified by:

broadcastInSameThread in interface EventBroadcaster

Parameters:

event - - the event

shutdown

public void shutdown()

Description copied from interface: EventBroadcaster

Waits for queued events to be processed and then shuts down

Specified by:

shutdown in interface EventBroadcaster