Class StompReactor
- java.lang.Object
-
- java.lang.Thread
-
- org.ovirt.vdsm.jsonrpc.client.reactors.Reactor
-
- org.ovirt.vdsm.jsonrpc.client.reactors.stomp.StompReactor
-
- All Implemented Interfaces:
java.lang.Runnable
public class StompReactor extends Reactor
-
-
Constructor Summary
Constructors Constructor Description StompReactor()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description ReactorClient
createClient(Reactor reactor, java.nio.channels.Selector selector, java.lang.String hostname, int port)
ReactorClient
createConnectedClient(Reactor reactor, java.nio.channels.Selector selector, java.lang.String hostname, int port, java.nio.channels.SocketChannel channel)
java.lang.String
getReactorName()
-
Methods inherited from class org.ovirt.vdsm.jsonrpc.client.reactors.Reactor
close, createClient, createListener, queueFuture, run, 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
-
getReactorName
public java.lang.String getReactorName()
- Specified by:
getReactorName
in classReactor
-
createClient
public ReactorClient createClient(Reactor reactor, java.nio.channels.Selector selector, java.lang.String hostname, int port) throws ClientConnectionException
- Specified by:
createClient
in classReactor
- Throws:
ClientConnectionException
-
createConnectedClient
public ReactorClient createConnectedClient(Reactor reactor, java.nio.channels.Selector selector, java.lang.String hostname, int port, java.nio.channels.SocketChannel channel) throws ClientConnectionException
- Specified by:
createConnectedClient
in classReactor
- Throws:
ClientConnectionException
-
-