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

Class ResponseTracker

java.lang.Object

org.ovirt.vdsm.jsonrpc.client.internal.ResponseTracker

All Implemented Interfaces:

java.lang.Runnable

public class ResponseTracker
extends java.lang.Object
implements java.lang.Runnable

Response tracker thread is responsible for tracking and retrying requests. For each connection there is single instance of the thread.

Constructor Summary

Constructors

Constructor	Description
ResponseTracker()

Method Summary

Modifier and Type	Method	Description
void	close()
protected java.util.Map<java.lang.String,java.util.List<com.fasterxml.jackson.databind.JsonNode>>	getHostMap()
protected void	loop()
void	processIssue(JsonRpcResponse response)
void	registerCall(JsonRpcRequest req, JsonRpcCall call)
void	registerTrackingRequest(JsonRpcRequest req, ResponseTracking tracking)
JsonRpcCall	removeCall(com.fasterxml.jackson.databind.JsonNode id)
void	run()
void	setExecutorService(java.util.concurrent.ScheduledExecutorService executorService)

Methods inherited from class java.lang.Object

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

Constructor Detail

ResponseTracker

public ResponseTracker()

Method Detail

registerCall

public void registerCall(JsonRpcRequest req,
                         JsonRpcCall call)

removeCall

public JsonRpcCall removeCall(com.fasterxml.jackson.databind.JsonNode id)

registerTrackingRequest

public void registerTrackingRequest(JsonRpcRequest req,
                                    ResponseTracking tracking)

run

public void run()

Specified by:

run in interface java.lang.Runnable

loop

protected void loop()

close

public void close()

setExecutorService

public void setExecutorService(java.util.concurrent.ScheduledExecutorService executorService)

processIssue

public void processIssue(JsonRpcResponse response)

getHostMap

protected java.util.Map<java.lang.String,java.util.List<com.fasterxml.jackson.databind.JsonNode>> getHostMap()