org.elasticsearch.transport

Class TransportService.Adapter

java.lang.Object

org.elasticsearch.transport.TransportService.Adapter

All Implemented Interfaces:

TransportServiceAdapter

Enclosing class:

TransportService

protected class TransportService.Adapter
extends Object
implements TransportServiceAdapter

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	Adapter()

Method Summary

Modifier and Type	Method and Description
String	action(String action, Version version)
protected void	checkForTimeout(long requestId)
TransportRequestHandler	handler(String action, Version version)
void	onRequestReceived(long requestId, String action) called by the {@link 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, String action, TransportRequest request, TransportRequestOptions options) called by the Transport implementation once a request has been sent
TransportResponseHandler	onResponseReceived(long requestId) called by the {@link Transport) implementation when a response or an exception has been recieved for a previously sent request (before any processing or deserialization was done).
void	onResponseSent(long requestId, String action, Throwable t) called by the {@link Transport) implementation after an exception was sent as a response to an incoming request
void	onResponseSent(long requestId, String action, TransportResponse response, TransportResponseOptions options) called by the {@link Transport) implementation once a response was sent to calling node
void	raiseNodeConnected(DiscoveryNode node)
void	raiseNodeDisconnected(DiscoveryNode node)
void	received(long size)
void	sent(long size)
protected boolean	traceEnabled()
protected void	traceReceivedRequest(long requestId, String action)
protected void	traceReceivedResponse(long requestId, DiscoveryNode sourceNode, String action)
protected void	traceRequestSent(DiscoveryNode node, long requestId, String action, TransportRequestOptions options)
protected void	traceResponseSent(long requestId, String action)
protected void	traceResponseSent(long requestId, String action, Throwable t)
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

received

public void received(long size)

Specified by:

received in interface TransportServiceAdapter

sent

public void sent(long size)

Specified by:

sent in interface TransportServiceAdapter

onRequestSent

public void onRequestSent(DiscoveryNode node,
                          long requestId,
                          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,
                           String action,
                           TransportResponse response,
                           TransportResponseOptions options)

Description copied from interface: TransportServiceAdapter

called by the {@link Transport) implementation once a response was sent to calling node

Specified by:

onResponseSent in interface TransportServiceAdapter

onResponseSent

public void onResponseSent(long requestId,
                           String action,
                           Throwable t)

Description copied from interface: TransportServiceAdapter

called by the {@link 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,
                                 String action,
                                 Throwable t)

onRequestReceived

public void onRequestReceived(long requestId,
                              String action)

Description copied from interface: TransportServiceAdapter

called by the {@link 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

handler

public TransportRequestHandler handler(String action,
                                       Version version)

Specified by:

handler in interface TransportServiceAdapter

onResponseReceived

public TransportResponseHandler onResponseReceived(long requestId)

Description copied from interface: TransportServiceAdapter

called by the {@link Transport) implementation when a response or an exception has been recieved 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)

raiseNodeConnected

public void raiseNodeConnected(DiscoveryNode node)

Specified by:

raiseNodeConnected in interface TransportServiceAdapter

raiseNodeDisconnected

public void raiseNodeDisconnected(DiscoveryNode node)

Specified by:

raiseNodeDisconnected in interface TransportServiceAdapter

action

public String action(String action,
                     Version version)

Specified by:

action in interface TransportServiceAdapter

traceReceivedRequest

protected void traceReceivedRequest(long requestId,
                                    String action)

traceResponseSent

protected void traceResponseSent(long requestId,
                                 String action)

traceReceivedResponse

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

traceUnresolvedResponse

protected void traceUnresolvedResponse(long requestId)

traceRequestSent

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