com.metamatrix.core.event
Class AsynchEventBroker

java.lang.Object
  extended by com.metamatrix.core.event.AbstractEventSource
      extended by com.metamatrix.core.event.AbstractEventBroker
          extended by com.metamatrix.core.event.AsynchEventBroker
All Implemented Interfaces:
EventBroker, EventObjectListener, EventSource, java.util.EventListener

public class AsynchEventBroker
extends AbstractEventBroker


Constructor Summary
AsynchEventBroker()
           
AsynchEventBroker(java.lang.String name)
           
 
Method Summary
 boolean hasUnprocessedEvents()
          Return whether this broker has at least one event that has yet to be processed and sent to the appropriate listeners.
protected  void process(java.util.EventObject obj)
          Add an object to the queue.
protected  void waitToCompleteShutdown()
           
 
Methods inherited from class com.metamatrix.core.event.AbstractEventBroker
addListener, addListener, assertReady, getName, isShutdown, isShutdownComplete, isShutdownRequested, notifyListeners, processEvent, setName, setShutdownComplete, shutdown, toString
 
Methods inherited from class com.metamatrix.core.event.AbstractEventSource
addListeners, getAllListeners, getListeners, getListeners, removeAllListeners, removeListener, removeListener
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 
Methods inherited from interface com.metamatrix.core.event.EventSource
getAllListeners, getListeners, getListeners, removeAllListeners, removeListener, removeListener
 

Constructor Detail

AsynchEventBroker

public AsynchEventBroker()

AsynchEventBroker

public AsynchEventBroker(java.lang.String name)
Method Detail

hasUnprocessedEvents

public boolean hasUnprocessedEvents()
Return whether this broker has at least one event that has yet to be processed and sent to the appropriate listeners.

Returns:
true if there are events that have yet to be processed, or false otherwise.

process

protected final void process(java.util.EventObject obj)
Add an object to the queue. This method assumes that the EventObject reference is never null and that the broker is not suspended.

Specified by:
process in class AbstractEventBroker

waitToCompleteShutdown

protected void waitToCompleteShutdown()
Specified by:
waitToCompleteShutdown in class AbstractEventBroker


Copyright © 2009. All Rights Reserved.