org.jredis.ri.alphazero.connection

Class PendingRequest

java.lang.Object

org.jredis.ri.alphazero.connection.PendingRequest

All Implemented Interfaces:

Future<Response>

public class PendingRequest
extends Object
implements Future<Response>

An implementation of Future for parameteric T type Response used for processing of pipelined responses from the server.

Note that this implementation does NOT support canceling of Requests.

Since:

alpha.0

Version:

alpha.0, Sep 7, 2009

Author:

Joubin Houshyar (alphazero@sensesay.net)

Constructor Summary

Constructors

Constructor and Description
PendingRequest(Command cmd)
PendingRequest(Command cmd, byte[]... args)

Method Summary

Modifier and Type	Method and Description
boolean	cancel(boolean mayInterruptIfRunning) Pipeline does not support canceling of requests -- will always return false.
Response	get()
Response	get(long timeout, TimeUnit unit)
boolean	isCancelled() Pipeline does not support canceling of requests -- will always return false.
boolean	isDone()

Methods inherited from class java.lang.Object

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

Constructor Detail

PendingRequest

public PendingRequest(Command cmd)

PendingRequest

public PendingRequest(Command cmd,
                      byte[]... args)

Method Detail

get

public Response get()
             throws InterruptedException,
                    ExecutionException

Specified by:

get in interface Future<Response>

Throws:

InterruptedException

ExecutionException

get

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

Specified by:

get in interface Future<Response>

Throws:

InterruptedException

ExecutionException

TimeoutException

cancel

public boolean cancel(boolean mayInterruptIfRunning)

Pipeline does not support canceling of requests -- will always return false.

Specified by:

cancel in interface Future<Response>

See Also:

Future.cancel(boolean)

isCancelled

public boolean isCancelled()

Pipeline does not support canceling of requests -- will always return false.

Specified by:

isCancelled in interface Future<Response>

See Also:

cancel(boolean), Future.isCancelled()

isDone

public boolean isDone()

Specified by:

isDone in interface Future<Response>