org.ovirt.vdsm.jsonrpc.client.internal

Class BatchCall

java.lang.Object

org.ovirt.vdsm.jsonrpc.client.internal.BatchCall

All Implemented Interfaces:

Future<List<JsonRpcResponse>>, JsonRpcCall

public class BatchCall
extends Object
implements Future<List<JsonRpcResponse>>, JsonRpcCall

Groups responses for batch call and let user to get them when all of them are ready.

Constructor Summary

Constructors

Constructor and Description
BatchCall(List<JsonRpcRequest> requests)

Method Summary

Methods

Modifier and Type	Method and Description
void	addResponse(JsonRpcResponse response)
boolean	cancel(boolean cancel)
List<JsonRpcResponse>	get()
List<JsonRpcResponse>	get(long time, TimeUnit unit)
List<org.codehaus.jackson.JsonNode>	getId()
boolean	isCancelled()
boolean	isDone()

Methods inherited from class java.lang.Object

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

Constructor Detail

BatchCall

public BatchCall(List<JsonRpcRequest> requests)

Method Detail

addResponse

public void addResponse(JsonRpcResponse response)

Specified by:

addResponse in interface JsonRpcCall

Parameters:

response - Added to current call object.

cancel

public boolean cancel(boolean cancel)

Specified by:

cancel in interface Future<List<JsonRpcResponse>>

get

public List<JsonRpcResponse> get()
                          throws InterruptedException,
                                 ExecutionException

Specified by:

get in interface Future<List<JsonRpcResponse>>

Throws:

InterruptedException

ExecutionException

get

public List<JsonRpcResponse> get(long time,
                        TimeUnit unit)
                          throws InterruptedException,
                                 ExecutionException,
                                 TimeoutException

Specified by:

get in interface Future<List<JsonRpcResponse>>

Throws:

InterruptedException

ExecutionException

TimeoutException

isCancelled

public boolean isCancelled()

Specified by:

isCancelled in interface Future<List<JsonRpcResponse>>

isDone

public boolean isDone()

Specified by:

isDone in interface Future<List<JsonRpcResponse>>

getId

public List<org.codehaus.jackson.JsonNode> getId()