Class Reactor
- java.lang.Object
-
- java.lang.Thread
-
- org.ovirt.vdsm.jsonrpc.client.reactors.Reactor
-
- All Implemented Interfaces:
java.lang.Runnable
- Direct Known Subclasses:
SSLStompReactor
,StompReactor
public abstract class Reactor extends java.lang.Thread
ProvidesReactor
abstraction which reacts on incoming messages and letReactorClient
process them.
-
-
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
-
-
-
-
Method Detail
-
run
public void run()
Main loop for message processing.- Specified by:
run
in interfacejava.lang.Runnable
- Overrides:
run
in classjava.lang.Thread
-
queueFuture
public void queueFuture(java.util.concurrent.Future<?> f)
-
wakeup
public void wakeup()
-
createListener
public java.util.concurrent.Future<ReactorListener> createListener(java.lang.String hostname, int port, ReactorListener.EventListener owner)
-
createClient
public ReactorClient createClient(java.lang.String hostname, int port) throws ClientConnectionException
- Throws:
ClientConnectionException
-
close
public void close()
-
createClient
protected abstract ReactorClient createClient(Reactor reactor, java.nio.channels.Selector selector, java.lang.String hostname, int port) throws ClientConnectionException
- Throws:
ClientConnectionException
-
createConnectedClient
protected abstract ReactorClient createConnectedClient(Reactor reactor, java.nio.channels.Selector selector, java.lang.String hostname, int port, java.nio.channels.SocketChannel channel) throws ClientConnectionException
- Throws:
ClientConnectionException
-
getReactorName
protected abstract java.lang.String getReactorName()
-
-