org.elasticsearch.transport

Interface TransportServiceAdapter

All Superinterfaces:

TransportConnectionListener

All Known Implementing Classes:

TransportService.Adapter

public interface TransportServiceAdapter
extends TransportConnectionListener

Method Summary

Modifier and Type	Method and Description
void	addBytesReceived(long size)
void	addBytesSent(long size)
RequestHandlerRegistry	getRequestHandler(java.lang.String action)
void	onRequestReceived(long requestId, java.lang.String action) called by the Transport implementation when an incoming request arrives but before any parsing of it has happened (with the exception of the requestId and action)
void	onRequestSent(DiscoveryNode node, long requestId, java.lang.String action, TransportRequest request, TransportRequestOptions options) called by the Transport implementation once a request has been sent
TransportResponseHandler	onResponseReceived(long requestId) 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).
void	onResponseSent(long requestId, java.lang.String action, java.lang.Exception e) called by the Transport implementation after an exception was sent as a response to an incoming request
void	onResponseSent(long requestId, java.lang.String action, TransportResponse response, TransportResponseOptions options) called by the Transport implementation once a response was sent to calling node

Methods inherited from interface org.elasticsearch.transport.TransportConnectionListener

onConnectionClosed, onConnectionOpened, onNodeConnected, onNodeDisconnected

Method Detail

addBytesReceived

void addBytesReceived(long size)

addBytesSent

void addBytesSent(long size)

onRequestSent

void onRequestSent(DiscoveryNode node,
                   long requestId,
                   java.lang.String action,
                   TransportRequest request,
                   TransportRequestOptions options)

called by the Transport implementation once a request has been sent

onResponseSent

void onResponseSent(long requestId,
                    java.lang.String action,
                    TransportResponse response,
                    TransportResponseOptions options)

called by the Transport implementation once a response was sent to calling node

onResponseSent

void onResponseSent(long requestId,
                    java.lang.String action,
                    java.lang.Exception e)

called by the Transport implementation after an exception was sent as a response to an incoming request

onResponseReceived

TransportResponseHandler onResponseReceived(long requestId)

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.

onRequestReceived

void onRequestReceived(long requestId,
                       java.lang.String action)

called by the Transport implementation when an incoming request arrives but before any parsing of it has happened (with the exception of the requestId and action)

getRequestHandler

RequestHandlerRegistry getRequestHandler(java.lang.String action)