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

Class Call

java.lang.Object

org.ovirt.vdsm.jsonrpc.client.internal.Call

All Implemented Interfaces:

Future<JsonRpcResponse>, JsonRpcCall

public class Call
extends Object
implements Future<JsonRpcResponse>, JsonRpcCall

Call holds single response

Nested Class Summary

Nested classes/interfaces inherited from interface java.util.concurrent.Future

Future.State

Field Summary

Fields

Modifier and Type	Field	Description
private BrokerCommandCallback	callback
private final com.fasterxml.jackson.databind.JsonNode	id
private final CountDownLatch	latch
private JsonRpcResponse	response

Constructor Summary

Constructors

Constructor	Description
Call(JsonRpcRequest req)
Call(JsonRpcRequest req, BrokerCommandCallback callback)

Method Summary

Modifier and Type	Method	Description
void	addResponse(JsonRpcResponse response)
boolean	cancel(boolean mayInterruptIfRunning)
JsonRpcResponse	get()
JsonRpcResponse	get(long timeout, TimeUnit unit)
BrokerCommandCallback	getCallback()	The callback to notify after the specific command was invoked.
com.fasterxml.jackson.databind.JsonNode	getId()
boolean	isCancelled()
boolean	isDone()

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.concurrent.Future

exceptionNow, resultNow, state

Field Details

latch

private final CountDownLatch latch

id

private final com.fasterxml.jackson.databind.JsonNode id

response

private JsonRpcResponse response

callback

private BrokerCommandCallback callback

Constructor Details

Call

public Call(JsonRpcRequest req)

Call

public Call(JsonRpcRequest req,
 BrokerCommandCallback callback)

Method Details

cancel

public boolean cancel(boolean mayInterruptIfRunning)

Specified by:

cancel in interface Future<JsonRpcResponse>

addResponse

public void addResponse(JsonRpcResponse response)

Specified by:

addResponse in interface JsonRpcCall

Parameters:

response - Added to current call object.

getId

public com.fasterxml.jackson.databind.JsonNode getId()

get

public JsonRpcResponse get()
                    throws InterruptedException

Specified by:

get in interface Future<JsonRpcResponse>

Throws:

InterruptedException

get

public JsonRpcResponse get(long timeout,
 TimeUnit unit)
                    throws InterruptedException,
TimeoutException

Specified by:

get in interface Future<JsonRpcResponse>

Throws:

InterruptedException

TimeoutException

isCancelled

public boolean isCancelled()

Specified by:

isCancelled in interface Future<JsonRpcResponse>

isDone

public boolean isDone()

Specified by:

isDone in interface Future<JsonRpcResponse>

getCallback

public BrokerCommandCallback getCallback()

Description copied from interface: JsonRpcCall

The callback to notify after the specific command was invoked.

Specified by:

getCallback in interface JsonRpcCall

Returns:

The callback that receives the notification.