org.globus.cog.karajan.workflow.events
Class EventBus.CriticalEventBus

java.lang.Object
  extended byjava.lang.Thread
      extended byorg.globus.cog.karajan.workflow.events.EventBus
          extended byorg.globus.cog.karajan.workflow.events.EventBus.CriticalEventBus
All Implemented Interfaces:
Runnable
Enclosing class:
EventBus

public static final class EventBus.CriticalEventBus
extends EventBus


Nested Class Summary
 
Nested classes inherited from class org.globus.cog.karajan.workflow.events.EventBus
EventBus.CriticalEventBus
 
Field Summary
 
Fields inherited from class org.globus.cog.karajan.workflow.events.EventBus
countThreshold, cummulativeEventTime, DEFAULT_COUNT_THRESHOLD, DEFAULT_MAX_SEND_TIME, DEFAULT_MIN_CRITICAL_THREADS, endEvents, MAX_QUEUED_EVENTS, maxCriticalThreads, maxSendTime, minCriticalThreads, startEvents
 
Fields inherited from class java.lang.Thread
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY
 
Constructor Summary
EventBus.CriticalEventBus()
           
 
Method Summary
 long getLastSendStart()
           
 boolean isBlocked()
           
protected  void sendT(EventListener fel, Event fee)
           
 void setBlocked(boolean blocked)
           
 String toString()
           
 
Methods inherited from class org.globus.cog.karajan.workflow.events.EventBus
addCriticalBus, dequeue, getAllEvents, getCountThreshold, getCurrentCriticalThreads, getEvents, getMaxSendTime, getMinCriticalThreads, getQueueSize, initialize, initializeCriticalThreads, isInitialized, isSleeping, isSuspended, isTerminateOnEmptyQueue, newEventBus, post, postT, removeCriticalBus, removeEventHook, resumeAll, resumeAll, resumeT, run, send, setCountThreshold, setEventHook, setMaxSendTime, setMinCriticalThreads, setTerminateOnEmptyQueue, shutdown, shutdownT, suspendAll, suspendAll, suspendT, waitForEvents
 
Methods inherited from class java.lang.Thread
activeCount, checkAccess, countStackFrames, currentThread, destroy, dumpStack, enumerate, getContextClassLoader, getName, getPriority, getThreadGroup, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setName, setPriority, sleep, sleep, start, stop, stop, suspend, yield
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Constructor Detail

EventBus.CriticalEventBus

public EventBus.CriticalEventBus()
Method Detail

sendT

protected void sendT(EventListener fel,
                     Event fee)
Overrides:
sendT in class EventBus

getLastSendStart

public long getLastSendStart()

toString

public String toString()

isBlocked

public boolean isBlocked()

setBlocked

public void setBlocked(boolean blocked)