org.openorb.notify.queue
Class EventQueueDispatcher
public
class
EventQueueDispatcher
extends NotifyThread
Author: Olivier Modica Shawn Boyce
Method Summary |
void | pushEvent(Object event)
This method is invoked by the proxy upon receipt of a new event.
|
void | pushEvents(Object[] events)
This method is invoked by the proxy upon receipt of a new event.
|
void | run()
The run method waits for new events and pulls them from the queue |
void | stopThread()
Stop the thread |
Default constructor
public void pushEvent(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.
public void pushEvents(Object[] events)
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.
public void run()
The run method waits for new events and pulls them from the queue
public void stopThread()
Stop the thread