|
OpenNMS API 1.2.3 | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.opennms.netmgt.eventd.EventIpcManagerDefaultImpl.ListenerThread
A thread dedicated to each listener. The events meant for each listener is added to a dedicated queue when the 'sendNow()' is called. The ListenerThread reads events off of this queue and sends it to the appropriate listener
Field Summary | |
private java.lang.Thread |
m_delegateThread
The thread that is running this runnable. |
private EventListener |
m_listener
Listener to which this thread is dedicated |
private FifoQueue |
m_queue
Queue from which events for the listener are to be read |
private boolean |
m_shutdown
if set true then the thread should exist as soon as possible. |
Constructor Summary | |
(package private) |
EventIpcManagerDefaultImpl.ListenerThread(EventListener listener,
FifoQueue lq)
Constructor |
Method Summary | |
FifoQueue |
getQueue()
|
void |
run()
The run method preforms the actual work for the runnable. |
void |
start()
Starts up the thread. |
void |
stop()
Sets the stop flag in the thread. |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
private EventListener m_listener
private FifoQueue m_queue
private java.lang.Thread m_delegateThread
private volatile boolean m_shutdown
Constructor Detail |
EventIpcManagerDefaultImpl.ListenerThread(EventListener listener, FifoQueue lq)
Method Detail |
public FifoQueue getQueue()
public void run()
Event
. After each
event is read, the 'onEvent' method of the listener is invoked.
run
in interface java.lang.Runnable
public void start()
public void stop()
|
OpenNMS API 1.2.3 | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |