org.elasticsearch.transport

Class TransportService.Adapter

java.lang.Object

org.elasticsearch.transport.TransportService.Adapter

All Implemented Interfaces:

TransportConnectionListener, TransportServiceAdapter

Enclosing class:

TransportService

protected class TransportService.Adapter
extends java.lang.Object
implements TransportServiceAdapter

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	Adapter()

Method Summary

Modifier and Type	Method and Description
void	addBytesReceived(long size)
void	addBytesSent(long size)
protected void	checkForTimeout(long requestId)
RequestHandlerRegistry	getRequestHandler(java.lang.String action)
void	onConnectionClosed(Transport.Connection connection) Called once a node connection is closed.
void	onConnectionOpened(Transport.Connection connection) Called once a node connection is opened.
void	onNodeConnected(DiscoveryNode node) Called once a node connection is opened and registered.
void	onNodeDisconnected(DiscoveryNode node) Called once a node connection is closed and unregistered.
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
protected boolean	traceEnabled()
protected void	traceReceivedRequest(long requestId, java.lang.String action)
protected void	traceReceivedResponse(long requestId, DiscoveryNode sourceNode, java.lang.String action)
protected void	traceRequestSent(DiscoveryNode node, long requestId, java.lang.String action, TransportRequestOptions options)
protected void	traceResponseSent(long requestId, java.lang.String action)
protected void	traceResponseSent(long requestId, java.lang.String action, java.lang.Exception e)
protected void	traceUnresolvedResponse(long requestId)

Methods inherited from class java.lang.Object

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

Constructor Detail

Adapter

protected Adapter()

Method Detail

addBytesReceived

public void addBytesReceived(long size)

Specified by:

addBytesReceived in interface TransportServiceAdapter

addBytesSent

public void addBytesSent(long size)

Specified by:

addBytesSent in interface TransportServiceAdapter

onRequestSent

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

Description copied from interface: TransportServiceAdapter

called by the Transport implementation once a request has been sent

Specified by:

onRequestSent in interface TransportServiceAdapter

traceEnabled

protected boolean traceEnabled()

onResponseSent

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

Description copied from interface: TransportServiceAdapter

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

Specified by:

onResponseSent in interface TransportServiceAdapter

onResponseSent

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

Description copied from interface: TransportServiceAdapter

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

Specified by:

onResponseSent in interface TransportServiceAdapter

traceResponseSent

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

onRequestReceived

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

Description copied from interface: TransportServiceAdapter

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)

Specified by:

onRequestReceived in interface TransportServiceAdapter

getRequestHandler

public RequestHandlerRegistry getRequestHandler(java.lang.String action)

Specified by:

getRequestHandler in interface TransportServiceAdapter

onResponseReceived

public TransportResponseHandler onResponseReceived(long requestId)

Description copied from interface: TransportServiceAdapter

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.

Specified by:

onResponseReceived in interface TransportServiceAdapter

checkForTimeout

protected void checkForTimeout(long requestId)

onNodeConnected

public void onNodeConnected(DiscoveryNode node)

Description copied from interface: TransportConnectionListener

Called once a node connection is opened and registered.

Specified by:

onNodeConnected in interface TransportConnectionListener

onConnectionOpened

public void onConnectionOpened(Transport.Connection connection)

Description copied from interface: TransportConnectionListener

Called once a node connection is opened.

Specified by:

onConnectionOpened in interface TransportConnectionListener

onNodeDisconnected

public void onNodeDisconnected(DiscoveryNode node)

Description copied from interface: TransportConnectionListener

Called once a node connection is closed and unregistered.

Specified by:

onNodeDisconnected in interface TransportConnectionListener

onConnectionClosed

public void onConnectionClosed(Transport.Connection connection)

Description copied from interface: TransportConnectionListener

Called once a node connection is closed. The connection might not have been registered in the transport as a shared connection to a specific node

Specified by:

onConnectionClosed in interface TransportConnectionListener

traceReceivedRequest

protected void traceReceivedRequest(long requestId,
                                    java.lang.String action)

traceResponseSent

protected void traceResponseSent(long requestId,
                                 java.lang.String action)

traceReceivedResponse

protected void traceReceivedResponse(long requestId,
                                     DiscoveryNode sourceNode,
                                     java.lang.String action)

traceUnresolvedResponse

protected void traceUnresolvedResponse(long requestId)

traceRequestSent

protected void traceRequestSent(DiscoveryNode node,
                                long requestId,
                                java.lang.String action,
                                TransportRequestOptions options)