org.edg.info
Class MessengerWatcher

java.lang.Object
  extended byjava.lang.Thread
      extended byorg.edg.info.MessengerWatcher
All Implemented Interfaces:
java.lang.Runnable

public class MessengerWatcher
extends java.lang.Thread

Thread to watch fast messenger and reset it if it blocks on a single message for too long.

Author:
Stephen Hicks

Field Summary
 
Fields inherited from class java.lang.Thread
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY
 
Constructor Summary
MessengerWatcher(org.edg.info.Registrar registrar)
          Creates a new MessengerWatcher.
 
Method Summary
 void run()
          Periodically checks the current message in the fast queue and calls registrar.recreateFastMessenger() if it has been blocking for too long.
 
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, toString, yield
 
Methods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Constructor Detail

MessengerWatcher

public MessengerWatcher(org.edg.info.Registrar registrar)
Creates a new MessengerWatcher.

Parameters:
registrar - Reference to Registrar.
Method Detail

run

public void run()
Periodically checks the current message in the fast queue and calls registrar.recreateFastMessenger() if it has been blocking for too long.