Class ResponseWorker
- java.lang.Object
-
- java.lang.Thread
-
- org.ovirt.vdsm.jsonrpc.client.internal.ResponseWorker
-
- All Implemented Interfaces:
java.lang.Runnable
public final class ResponseWorker extends java.lang.Thread
ResponseWorker
is responsible to process responses for all theJsonRpcClient
and it is produced byReactorFactory
.
-
-
Constructor Summary
Constructors Constructor Description ResponseWorker(int parallelism, int eventTimeoutInHours)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
close()
EventPublisher
getPublisher()
JsonRpcClient
register(ReactorClient client)
Registers new client withResponseWorker
.void
run()
-
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
-
register
public JsonRpcClient register(ReactorClient client)
Registers new client withResponseWorker
.- Parameters:
client
- -JsonRpcClient
to be registered.- Returns:
- Client wrapper.
-
run
public void run()
- Specified by:
run
in interfacejava.lang.Runnable
- Overrides:
run
in classjava.lang.Thread
-
close
public void close()
-
getPublisher
public EventPublisher getPublisher()
- Returns:
- publisher which can be used to subscribe to events defined by subscription id.
-
-