org.openorb.notify.queue
Class EventQueueReceiver

java.lang.Object
  extended by org.openorb.notify.NotifyThread
      extended by org.openorb.notify.queue.EventQueueReceiver
All Implemented Interfaces:
java.lang.Runnable, ThreadManagement

public class EventQueueReceiver
extends NotifyThread

Author:
Olivier Modica, Shawn Boyce

Constructor Summary
EventQueueReceiver(java.lang.String id, EventQueue queue, org.apache.avalon.framework.logger.Logger logger)
          Default constructor
 
Method Summary
 void addDispatcher(EventDispatcher newDispatcher)
          This method adds a dispatcher
 void pushEvent(java.lang.Object event)
          This method is invoked by the proxy upon receipt of a new event.
 void removeDispatcher(EventDispatcher oldDispatcher)
          This method removes a dispatcher
 void run()
          The run method waits for new events and pushes them in the queue
 void stopThread()
          Stop the thread
 
Methods inherited from class org.openorb.notify.NotifyThread
finishWorkAndStopThread, getLogger, resumeThread, startThread, suspendThread, toString
 
Methods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Constructor Detail

EventQueueReceiver

public EventQueueReceiver(java.lang.String id,
                          EventQueue queue,
                          org.apache.avalon.framework.logger.Logger logger)
Default constructor

Method Detail

addDispatcher

public void addDispatcher(EventDispatcher newDispatcher)
This method adds a dispatcher


removeDispatcher

public void removeDispatcher(EventDispatcher oldDispatcher)
This method removes a dispatcher


pushEvent

public void pushEvent(java.lang.Object event)
This method is invoked by the proxy upon receipt of a new event. If the class is threaded ( call to start() ) then it returns immediately. Else it returns after delivering the event to the connected consumer.


run

public void run()
The run method waits for new events and pushes them in the queue


stopThread

public void stopThread()
Stop the thread

Specified by:
stopThread in interface ThreadManagement
Overrides:
stopThread in class NotifyThread