Package org.elasticsearch.transport

Class PlainTransportFuture<V extends TransportResponse>

java.lang.Object

org.elasticsearch.common.util.concurrent.BaseFuture<V>

org.elasticsearch.transport.PlainTransportFuture<V>

All Implemented Interfaces:

Future<V>, Writeable.Reader<V>, TransportFuture<V>, TransportResponseHandler<V>

public class PlainTransportFuture<V extends TransportResponse>
extends BaseFuture<V>
implements TransportFuture<V>, TransportResponseHandler<V>

Nested Class Summary

Nested classes/interfaces inherited from interface org.elasticsearch.transport.TransportResponseHandler

TransportResponseHandler.Empty

Constructor Summary

Constructors

Constructor	Description
PlainTransportFuture(TransportResponseHandler<V> handler)

Method Summary

Modifier and Type	Method	Description
String	executor()
void	handleException(TransportException exp)
void	handleResponse(V response)
V	read(StreamInput in)	Read V-type value from a stream.
String	toString()
V	txGet()	Waits if necessary for the computation to complete, and then retrieves its result.
V	txGet(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.

Methods inherited from class org.elasticsearch.common.util.concurrent.BaseFuture

blockingAllowed, cancel, done, get, get, interruptTask, isCancelled, isDone, set, setException

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.concurrent.Future

cancel, get, get, isCancelled, isDone

Methods inherited from interface org.elasticsearch.transport.TransportResponseHandler

wrap

Constructor Details

PlainTransportFuture

public PlainTransportFuture(TransportResponseHandler<V> handler)

Method Details

txGet

public V txGet()

Description copied from interface: TransportFuture

Waits if necessary for the computation to complete, and then retrieves its result.

Specified by:

txGet in interface TransportFuture<V extends TransportResponse>

txGet

public V txGet(long timeout,
 TimeUnit unit)

Description copied from interface: TransportFuture

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

Specified by:

txGet in interface TransportFuture<V extends TransportResponse>

read

public V read(StreamInput in)
       throws IOException

Description copied from interface: Writeable.Reader

Read V-type value from a stream.

Specified by:

read in interface Writeable.Reader<V extends TransportResponse>

Parameters:

in - Input to read the value from

Throws:

IOException

executor

public String executor()

Specified by:

executor in interface TransportResponseHandler<V extends TransportResponse>

handleResponse

public void handleResponse(V response)

Specified by:

handleResponse in interface TransportResponseHandler<V extends TransportResponse>

handleException

public void handleException(TransportException exp)

Specified by:

handleException in interface TransportResponseHandler<V extends TransportResponse>

toString

public String toString()

Overrides:

toString in class Object