Module org.elasticsearch.server

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

A registry of response handlers for in-flight transport requests. Keeps a map of request IDs to their relevant Transport.ResponseContext so that when a peer response is received, the appropriate handler can be invoked.

Constructor Summary

Constructors

Constructor	Description
ResponseHandlers()

Method Summary

Modifier and Type	Method	Description
Transport.ResponseContext<? extends TransportResponse>	add(TransportResponseHandler<? extends TransportResponse> handler, Transport.Connection connection, String action)	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 Transport.ResponseContext<? extends TransportResponse> add(TransportResponseHandler<? extends TransportResponse> handler,
 Transport.Connection connection,
 String action)

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

Returns:

the new response context

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.