com.aerospike.client.task

Class Task

java.lang.Object

com.aerospike.client.task.Task

Direct Known Subclasses:

ExecuteTask, IndexTask, RegisterTask

public abstract class Task
extends Object

Task used to poll for server task completion.

Field Summary

Fields

Modifier and Type	Field and Description
static int	COMPLETE
static int	IN_PROGRESS
static int	NOT_FOUND

Constructor Summary

Constructors

Constructor and Description
Task() Initialize task that has already completed.
Task(com.aerospike.client.cluster.Cluster cluster, Policy policy) Initialize task with fields needed to query server nodes.

Method Summary

Modifier and Type	Method and Description
boolean	isDone() Has task completed.
abstract int	queryStatus() Query all nodes for task completion status.
void	waitTillComplete() Wait for asynchronous task to complete using default sleep interval (1 second).
void	waitTillComplete(int sleepInterval) Wait for asynchronous task to complete using given sleep interval in milliseconds.
void	waitTillComplete(int sleepInterval, int timeout) Wait for asynchronous task to complete using given sleep interval and timeout in milliseconds.

Methods inherited from class java.lang.Object

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

Field Detail

NOT_FOUND

public static final int NOT_FOUND

See Also:

Constant Field Values

IN_PROGRESS

public static final int IN_PROGRESS

See Also:

Constant Field Values

COMPLETE

public static final int COMPLETE

See Also:

Constant Field Values

Constructor Detail

Task

public Task(com.aerospike.client.cluster.Cluster cluster,
            Policy policy)

Initialize task with fields needed to query server nodes.

Task

public Task()

Initialize task that has already completed.

Method Detail

waitTillComplete

public final void waitTillComplete()

Wait for asynchronous task to complete using default sleep interval (1 second). The timeout is passed from the original task policy. If task is not complete by timeout, an exception is thrown. Do not timeout if timeout set to zero.

waitTillComplete

public final void waitTillComplete(int sleepInterval)

Wait for asynchronous task to complete using given sleep interval in milliseconds. The timeout is passed from the original task policy. If task is not complete by timeout, an exception is thrown. Do not timeout if policy timeout set to zero.

waitTillComplete

public final void waitTillComplete(int sleepInterval,
                                   int timeout)

Wait for asynchronous task to complete using given sleep interval and timeout in milliseconds. If task is not complete by timeout, an exception is thrown. Do not timeout if timeout set to zero.

isDone

public final boolean isDone()

Has task completed.

queryStatus

public abstract int queryStatus()

Query all nodes for task completion status.