Module org.pdfsam.eventstudio

Package org.pdfsam.eventstudio

Class Station

java.lang.Object

org.pdfsam.eventstudio.Station

class Station
extends java.lang.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 Listeners	listeners
private static org.slf4j.Logger	LOG
private java.lang.String	name
private java.util.concurrent.ConcurrentMap<java.lang.Class<?>,java.util.concurrent.BlockingQueue<java.lang.Object>>	queues
private Supervisor	supervisor

Constructor Summary

Constructors

Constructor	Description
Station(java.lang.String name)

Method Summary

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

Methods inherited from class java.lang.Object

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

Field Detail

LOG

private static final org.slf4j.Logger LOG

queues

private final java.util.concurrent.ConcurrentMap<java.lang.Class<?>,java.util.concurrent.BlockingQueue<java.lang.Object>> queues

listeners

private final Listeners listeners

supervisor

private volatile Supervisor supervisor

name

private final java.lang.String name

Constructor Detail

Station

Station(java.lang.String name)

Method Detail

getQueue

private java.util.concurrent.BlockingQueue<java.lang.Object> getQueue(java.lang.Class<?> clazz)

broadcast

public void broadcast(java.lang.Object event)

doBroadcast

private boolean doBroadcast(java.lang.Object event)

add

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

add

<T> void add(java.lang.Class<T> eventClass,
             Listener<T> listener,
             int priority,
             ReferenceStrength strength)

addAll

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

broadcastEnqueuedEventsFor

private void broadcastEnqueuedEventsFor(java.lang.Class<?> updatedClass)

remove

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

remove

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

name

java.lang.String name()

Returns:

name of the station

supervior

public void supervior(Supervisor supervisor)

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object