Class Reactor

  • All Implemented Interfaces:
    java.lang.Runnable
    Direct Known Subclasses:
    SSLStompReactor, StompReactor

    public abstract class Reactor
    extends java.lang.Thread
    Provides Reactor abstraction which reacts on incoming messages and let ReactorClient process them.
    • Nested Class Summary

      • Nested classes/interfaces inherited from class java.lang.Thread

        java.lang.Thread.State, java.lang.Thread.UncaughtExceptionHandler
    • Field Summary

      • Fields inherited from class java.lang.Thread

        MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY
    • Constructor Summary

      Constructors 
      Constructor Description
      Reactor()  
    • Method Summary

      All Methods Instance Methods Abstract Methods Concrete Methods 
      Modifier and Type Method Description
      void close()  
      ReactorClient createClient​(java.lang.String hostname, int port)  
      protected abstract ReactorClient createClient​(Reactor reactor, java.nio.channels.Selector selector, java.lang.String hostname, int port)  
      protected abstract ReactorClient createConnectedClient​(Reactor reactor, java.nio.channels.Selector selector, java.lang.String hostname, int port, java.nio.channels.SocketChannel channel)  
      java.util.concurrent.Future<ReactorListener> createListener​(java.lang.String hostname, int port, ReactorListener.EventListener owner)  
      protected abstract java.lang.String getReactorName()  
      void queueFuture​(java.util.concurrent.Future<?> f)  
      void run()
      Main loop for message processing.
      void wakeup()  
      • Methods inherited from class java.lang.Thread

        activeCount, checkAccess, clone, countStackFrames, currentThread, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, onSpinWait, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, suspend, toString, yield
      • Methods inherited from class java.lang.Object

        equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
    • Constructor Detail

      • Reactor

        public Reactor()
                throws java.io.IOException
        Throws:
        java.io.IOException