Package org.ovirt.vdsm.jsonrpc.client.internal

Class ResponseWorker

java.lang.Object

java.lang.Thread

org.ovirt.vdsm.jsonrpc.client.internal.ResponseWorker

All Implemented Interfaces:

Runnable

public final class ResponseWorker
extends Thread

ResponseWorker is responsible to process responses for all the JsonRpcClient and it is produced by ReactorFactory.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static class	ResponseWorker.ResponseForkJoinWorkerThread

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

Thread.Builder, Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields

Modifier and Type	Field	Description
private static final org.slf4j.Logger	log
private static final com.fasterxml.jackson.databind.ObjectMapper	MAPPER
private final EventPublisher	publisher
private final LinkedBlockingQueue<MessageContext>	queue
private static final Pattern	SENSITIVE_DATA_PATTERN
private final ResponseTracker	tracker

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor	Description
ResponseWorker(int parallelism, int eventTimeoutInHours)

Method Summary

Modifier and Type	Method	Description
void	close()
EventPublisher	getPublisher()
private void	processIncomingObject(JsonRpcClient client, com.fasterxml.jackson.databind.JsonNode node)
private void	processNotifications(JsonRpcEvent notification)
JsonRpcClient	register(ReactorClient client)	Registers new client with ResponseWorker.
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, isVirtual, join, join, join, join, ofPlatform, ofVirtual, onSpinWait, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, sleep, start, startVirtualThread, stop, suspend, threadId, toString, yield

Methods inherited from class java.lang.Object

equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Details

queue

private final LinkedBlockingQueue<MessageContext> queue

MAPPER

private static final com.fasterxml.jackson.databind.ObjectMapper MAPPER

tracker

private final ResponseTracker tracker

publisher

private final EventPublisher publisher

log

private static final org.slf4j.Logger log

SENSITIVE_DATA_PATTERN

private static final Pattern SENSITIVE_DATA_PATTERN

Constructor Details

ResponseWorker

public ResponseWorker(int parallelism,
 int eventTimeoutInHours)

Method Details

register

public JsonRpcClient register(ReactorClient client)

Registers new client with ResponseWorker.

Parameters:

client - - JsonRpcClient to be registered.

Returns:

Client wrapper.

run

public void run()

Specified by:

run in interface Runnable

Overrides:

run in class Thread

processIncomingObject

private void processIncomingObject(JsonRpcClient client,
 com.fasterxml.jackson.databind.JsonNode node)

processNotifications

private void processNotifications(JsonRpcEvent notification)

close

public void close()

getPublisher

public EventPublisher getPublisher()

Returns:

publisher which can be used to subscribe to events defined by subscription id.