protected class TransportService.Adapter extends Object implements TransportServiceAdapter
Modifier | Constructor and Description |
---|---|
protected |
Adapter() |
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) |
public void received(long size)
received
in interface TransportServiceAdapter
public void sent(long size)
sent
in interface TransportServiceAdapter
public void onRequestSent(DiscoveryNode node, long requestId, String action, TransportRequest request, TransportRequestOptions options)
TransportServiceAdapter
Transport
implementation once a request has been sentonRequestSent
in interface TransportServiceAdapter
protected boolean traceEnabled()
public void onResponseSent(long requestId, String action, TransportResponse response, TransportResponseOptions options)
TransportServiceAdapter
onResponseSent
in interface TransportServiceAdapter
public void onResponseSent(long requestId, String action, Throwable t)
TransportServiceAdapter
onResponseSent
in interface TransportServiceAdapter
public void onRequestReceived(long requestId, String action)
TransportServiceAdapter
onRequestReceived
in interface TransportServiceAdapter
public TransportRequestHandler handler(String action, Version version)
handler
in interface TransportServiceAdapter
public TransportResponseHandler onResponseReceived(long requestId)
TransportServiceAdapter
onResponseReceived
in interface TransportServiceAdapter
protected void checkForTimeout(long requestId)
public void raiseNodeConnected(DiscoveryNode node)
raiseNodeConnected
in interface TransportServiceAdapter
public void raiseNodeDisconnected(DiscoveryNode node)
raiseNodeDisconnected
in interface TransportServiceAdapter
public String action(String action, Version version)
action
in interface TransportServiceAdapter
protected void traceReceivedRequest(long requestId, String action)
protected void traceResponseSent(long requestId, String action)
protected void traceReceivedResponse(long requestId, DiscoveryNode sourceNode, String action)
protected void traceUnresolvedResponse(long requestId)
protected void traceRequestSent(DiscoveryNode node, long requestId, String action, TransportRequestOptions options)
Copyright © 2009–2015. All rights reserved.