Package org.elasticsearch.transport

Class Transport.ResponseHandlers

java.lang.Object

org.elasticsearch.transport.Transport.ResponseHandlers

Enclosing interface:

Transport

public static final class Transport.ResponseHandlers
extends Object

This class is a registry that allows

Constructor Summary

Constructors

Constructor	Description
ResponseHandlers()

Method Summary

Modifier and Type	Method	Description
long	add(Transport.ResponseContext<? extends TransportResponse> holder)	Adds a new response context and associates it with a new request ID.
boolean	contains(long requestId)	Returns true if the give request ID has a context associated with it.
TransportResponseHandler<? extends TransportResponse>	onResponseReceived(long requestId, TransportMessageListener listener)	called by the Transport implementation when a response or an exception has been received for a previously sent request (before any processing or deserialization was done).
List<Transport.ResponseContext<? extends TransportResponse>>	prune(Predicate<Transport.ResponseContext<? extends TransportResponse>> predicate)	Removes and returns all Transport.ResponseContext instances that match the predicate
Transport.ResponseContext<? extends TransportResponse>	remove(long requestId)	Removes and return the Transport.ResponseContext for the given request ID or returns null if no context is associated with this request ID.

Methods inherited from class java.lang.Object

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

Constructor Details

ResponseHandlers

public ResponseHandlers()

Method Details

contains

public boolean contains(long requestId)

Returns true if the give request ID has a context associated with it.

remove

public Transport.ResponseContext<? extends TransportResponse> remove(long requestId)

Removes and return the Transport.ResponseContext for the given request ID or returns null if no context is associated with this request ID.

add

public long add(Transport.ResponseContext<? extends TransportResponse> holder)

Adds a new response context and associates it with a new request ID.

Returns:

the new request ID

See Also:

Transport.Connection.sendRequest(long, String, TransportRequest, TransportRequestOptions)

prune

public List<Transport.ResponseContext<? extends TransportResponse>> prune(Predicate<Transport.ResponseContext<? extends TransportResponse>> predicate)

Removes and returns all Transport.ResponseContext instances that match the predicate

onResponseReceived

public TransportResponseHandler<? extends TransportResponse> onResponseReceived(long requestId,
 TransportMessageListener listener)

called by the Transport implementation when a response or an exception has been received for a previously sent request (before any processing or deserialization was done). Returns the appropriate response handler or null if not found.