Module org.pdfsam.eventstudio

Package org.pdfsam.eventstudio

Class Station

java.lang.Object

org.pdfsam.eventstudio.Station

class Station
extends Object

A Station is a place where broadcaster events are actually transmitted to the registered Listeners

Field Summary

Fields

Modifier and Type	Field	Description
private final Listeners	listeners
private static final org.slf4j.Logger	LOG
private final String	name
private final ConcurrentMap<Class<?>,BlockingQueue<Object>>	queues
private Supervisor	supervisor

Constructor Summary

Constructors

Constructor	Description
Station(String name)

Method Summary

Modifier and Type	Method	Description
(package private) <T> void	add(Class<T> eventClass, Listener<T> listener, int priority, ReferenceStrength strength, boolean once)
(package private) <T> void	add(Listener<T> listener, int priority, ReferenceStrength strength, boolean once)
(package private) void	addAll(Object bean, List<Annotations.ReflectiveListenerDescriptor> descriptors)
void	broadcast(Object event)
private void	broadcastEnqueuedEventsFor(Class<?> updatedClass)
(package private) <T> void	clearEnqueuedEvents(Class<T> eventClass)
private boolean	doBroadcast(Object event)
private BlockingQueue<Object>	getQueue(Class<?> clazz)
(package private) String	name()
(package private) <T> boolean	remove(Class<T> eventClass, Listener<T> listener)
(package private) <T> boolean	remove(Listener<T> listener)
void	supervisor(Supervisor supervisor)
String	toString()

Methods inherited from class java.lang.Object

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

Field Details

LOG

private static final org.slf4j.Logger LOG

queues

private final ConcurrentMap<Class<?>,BlockingQueue<Object>> queues

listeners

private final Listeners listeners

supervisor

private volatile Supervisor supervisor

name

private final String name

Constructor Details

Station

Station(String name)

Method Details

getQueue

private BlockingQueue<Object> getQueue(Class<?> clazz)

broadcast

public void broadcast(Object event)

doBroadcast

private boolean doBroadcast(Object event)

add

<T> void add(Listener<T> listener,
 int priority,
 ReferenceStrength strength,
 boolean once)

add

<T> void add(Class<T> eventClass,
 Listener<T> listener,
 int priority,
 ReferenceStrength strength,
 boolean once)

addAll

void addAll(Object bean,
 List<Annotations.ReflectiveListenerDescriptor> descriptors)

broadcastEnqueuedEventsFor

private void broadcastEnqueuedEventsFor(Class<?> updatedClass)

remove

<T> boolean remove(Listener<T> listener)

remove

<T> boolean remove(Class<T> eventClass,
 Listener<T> listener)

clearEnqueuedEvents

<T> void clearEnqueuedEvents(Class<T> eventClass)

name

String name()

Returns:

name of the station

supervisor

public void supervisor(Supervisor supervisor)

toString

public String toString()

Overrides:

toString in class Object