com.basho.riak.client.core.netty

Class HealthCheckDecoder.HealthCheckFuture

java.lang.Object

com.basho.riak.client.core.netty.HealthCheckDecoder.HealthCheckFuture

All Implemented Interfaces:

RiakFuture<RiakMessage,Void>, Future<RiakMessage>

Enclosing class:

HealthCheckDecoder

public static class HealthCheckDecoder.HealthCheckFuture
extends Object
implements RiakFuture<RiakMessage,Void>

Constructor Summary

Constructors

Constructor and Description
HealthCheckFuture()

Method Summary

Modifier and Type	Method and Description
void	addListener(RiakFutureListener<RiakMessage,Void> listener) Add a listener to this RiakFuture.
void	await() Waits for this RiakFuture to be completed.
boolean	await(long timeout, TimeUnit unit) Waits for this RiakFuture to be completed for a set amount of time.
boolean	cancel(boolean mayInterruptIfRunning) Not supported due to limitations of the Riak API.
Throwable	cause() Return information about the operation and why it failed.
RiakMessage	get() Waits for this RiakFuture to be completed if necessary and returns the response if available.
RiakMessage	get(long timeout, TimeUnit unit) Waits if necessary for at most the given time for the computation to complete, and then retrieves its result, if available.
RiakMessage	getNow() Return the result without blocking or throwing an exception.
Void	getQueryInfo() Returns information related to the operation performed.
boolean	isCancelled()
boolean	isDone()
boolean	isSuccess() Determine if the operation completed successfully.
void	removeListener(RiakFutureListener<RiakMessage,Void> listener) Remove a listener from this RiakFuture.
void	setException(Throwable e)
void	setMessage(RiakMessage m)

Methods inherited from class java.lang.Object

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

Constructor Detail

HealthCheckFuture

public HealthCheckFuture()

Method Detail

cancel

public boolean cancel(boolean mayInterruptIfRunning)

Description copied from interface: RiakFuture

Not supported due to limitations of the Riak API.

At present time there is no way to cancel an operation sent to Riak. This method will never succeed and always return false.

Specified by:

cancel in interface RiakFuture<RiakMessage,Void>

Specified by:

cancel in interface Future<RiakMessage>

Returns:

always false.

isCancelled

public boolean isCancelled()

Specified by:

isCancelled in interface RiakFuture<RiakMessage,Void>

Specified by:

isCancelled in interface Future<RiakMessage>

isDone

public boolean isDone()

Specified by:

isDone in interface RiakFuture<RiakMessage,Void>

Specified by:

isDone in interface Future<RiakMessage>

get

public RiakMessage get()
                throws InterruptedException,
                       ExecutionException

Description copied from interface: RiakFuture

Waits for this RiakFuture to be completed if necessary and returns the response if available.

Specified by:

get in interface RiakFuture<RiakMessage,Void>

Specified by:

get in interface Future<RiakMessage>

Returns:

The response from the operation.

Throws:

InterruptedException - if the current thread was interrupted while waiting

ExecutionException - if the computation threw an exception

get

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

Description copied from interface: RiakFuture

Waits if necessary for at most the given time for the computation to complete, and then retrieves its result, if available.

Note that the timeout value here is how long you are willing to wait for this RiakFuture to complete. If you wish to set a timeout on the command itself, use the timeout() method provided in the command's associated builder.

Specified by:

get in interface RiakFuture<RiakMessage,Void>

Specified by:

get in interface Future<RiakMessage>

Parameters:

timeout - the amount of time to wait before returning.

unit - the unit of time.

Returns:

the response, or null if not completed or failed.

Throws:

InterruptedException - if the current thread was interrupted while waiting.

ExecutionException - if the computation threw an exception.

TimeoutException - if the wait timed out.

setException

public void setException(Throwable e)

setMessage

public void setMessage(RiakMessage m)

await

public void await()
           throws InterruptedException

Description copied from interface: RiakFuture

Waits for this RiakFuture to be completed.

Upon returning, the operation has completed. Checking isSuccess() tells you if it did so successfully.

Specified by:

await in interface RiakFuture<RiakMessage,Void>

Throws:

InterruptedException - if the current thread was interrupted while waiting

See Also:

RiakFuture.isSuccess()

await

public boolean await(long timeout,
                     TimeUnit unit)
              throws InterruptedException

Description copied from interface: RiakFuture

Waits for this RiakFuture to be completed for a set amount of time.

Note that the timeout value here is how long you are willing to wait for this RiakFuture to complete. Upon return you can check isDone() to see if the future has completed yet or not. The operation is still in progress if that returns false.

If you wish to set a timeout on the command itself, use the timeout() method provided in the command's associated builder.

Specified by:

await in interface RiakFuture<RiakMessage,Void>

Parameters:

timeout - the amount of time to wait before returning.

unit - the unit of time.

Returns:

true if the future completed and false if the waiting time elapsed before it completed

Throws:

InterruptedException - if the current thread was interrupted while waiting

See Also:

RiakFuture.isDone(), RiakFuture.isSuccess()

getNow

public RiakMessage getNow()

Description copied from interface: RiakFuture

Return the result without blocking or throwing an exception. If the future is not yet done or has failed this will return null. As it is possible that a null value is used to mark the future as successful you also need to check if the future is really done with RiakFuture.isDone() and not rely on the returned null value.

Specified by:

getNow in interface RiakFuture<RiakMessage,Void>

Returns:

The response, or null if the future is not yet completed or failed.

See Also:

RiakFuture.isDone(), RiakFuture.isSuccess()

isSuccess

public boolean isSuccess()

Description copied from interface: RiakFuture

Determine if the operation completed successfully.

Specified by:

isSuccess in interface RiakFuture<RiakMessage,Void>

Returns:

true if the operation succeeded, false if not yet completed or failed.

cause

public Throwable cause()

Description copied from interface: RiakFuture

Return information about the operation and why it failed.

Note this will return null if the operation completed successfully.

Specified by:

cause in interface RiakFuture<RiakMessage,Void>

Returns:

The exception thrown during the operation, or null if not set.

See Also:

RiakFuture.isSuccess()

getQueryInfo

public Void getQueryInfo()

Description copied from interface: RiakFuture

Returns information related to the operation performed.

Useful in async operations when you want to know what operation this future refers to.

Specified by:

getQueryInfo in interface RiakFuture<RiakMessage,Void>

Returns:

Information pertaining to the operation attached to this future.

addListener

public void addListener(RiakFutureListener<RiakMessage,Void> listener)

Description copied from interface: RiakFuture

Add a listener to this RiakFuture.

Specified by:

addListener in interface RiakFuture<RiakMessage,Void>

Parameters:

listener - a RiakFutureListener that will be notified when this RiakFuture completes.

removeListener

public void removeListener(RiakFutureListener<RiakMessage,Void> listener)

Description copied from interface: RiakFuture

Remove a listener from this RiakFuture.

Specified by:

removeListener in interface RiakFuture<RiakMessage,Void>

Parameters:

listener - The listener to remove.