org.apache.directory.ldap.client.api.future

Class ResponseFuture<R extends Response>

java.lang.Object

org.apache.directory.ldap.client.api.future.ResponseFuture<R>

Type Parameters:

R - The result type returned by this Future's get method

All Implemented Interfaces:

java.util.concurrent.Future<Response>

Direct Known Subclasses:

AddFuture, BindFuture, CompareFuture, DeleteFuture, ExtendedFuture, ModifyDnFuture, ModifyFuture, SearchFuture

public class ResponseFuture<R extends Response>
extends java.lang.Object
implements java.util.concurrent.Future<Response>

A Future implementation used in LdapConnection operations.

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	cancelled flag to determine if this future is cancelled
protected java.lang.Throwable	cause If the request has been cancelled because of an exception it will be stored here
protected LdapConnection	connection The connection used by the request
protected int	messageId The messageID for this future
protected java.util.concurrent.BlockingQueue<R>	queue the blocking queue holding LDAP responses

Constructor Summary

Constructors

Constructor and Description
ResponseFuture(LdapConnection connection, int messageId) Creates a new instance of ResponseFuture.

Method Summary

Modifier and Type	Method and Description
void	cancel() Cancel the Future
boolean	cancel(boolean mayInterruptIfRunning)
R	get()
R	get(long timeout, java.util.concurrent.TimeUnit unit)
java.lang.Throwable	getCause()
boolean	isCancelled()
boolean	isDone() This operation is not supported in this implementation of Future.
void	set(R response)
void	setCause(java.lang.Throwable cause) Associate a cause to the ResponseFuture
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

queue

protected java.util.concurrent.BlockingQueue<R extends Response> queue

the blocking queue holding LDAP responses

cancelled

protected boolean cancelled

flag to determine if this future is cancelled

cause

protected java.lang.Throwable cause

If the request has been cancelled because of an exception it will be stored here

messageId

protected int messageId

The messageID for this future

connection

protected LdapConnection connection

The connection used by the request

Constructor Detail

ResponseFuture

public ResponseFuture(LdapConnection connection,
                      int messageId)

Creates a new instance of ResponseFuture.

Parameters:

connection - The LdapConnection used by the request

messageId - The associated message ID

Method Detail

cancel

public boolean cancel(boolean mayInterruptIfRunning)

Specified by:

cancel in interface java.util.concurrent.Future<Response>

get

public R get()
      throws java.lang.InterruptedException,
             java.util.concurrent.ExecutionException

Specified by:

get in interface java.util.concurrent.Future<Response>

Throws:

java.lang.InterruptedException - if the operation has been cancelled by client

java.util.concurrent.ExecutionException

set

public void set(R response)
         throws java.lang.InterruptedException,
                java.util.concurrent.ExecutionException

Throws:

java.lang.InterruptedException - if the operation has been cancelled by client

java.util.concurrent.ExecutionException

get

public R get(long timeout,
             java.util.concurrent.TimeUnit unit)
      throws java.lang.InterruptedException,
             java.util.concurrent.ExecutionException,
             java.util.concurrent.TimeoutException

Specified by:

get in interface java.util.concurrent.Future<Response>

Throws:

java.lang.InterruptedException - if the operation has been cancelled by client

java.util.concurrent.ExecutionException

java.util.concurrent.TimeoutException

isCancelled

public boolean isCancelled()

Specified by:

isCancelled in interface java.util.concurrent.Future<Response>

isDone

public boolean isDone()

This operation is not supported in this implementation of Future.

Specified by:

isDone in interface java.util.concurrent.Future<Response>

getCause

public java.lang.Throwable getCause()

Returns:

the cause

setCause

public void setCause(java.lang.Throwable cause)

Associate a cause to the ResponseFuture

Parameters:

cause - the cause to set

cancel

public void cancel()

Cancel the Future

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object