public interface TransportServiceAdapter
Modifier and Type | Method and Description |
---|---|
String |
action(String action,
Version version) |
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) |
void received(long size)
void sent(long size)
void onRequestSent(DiscoveryNode node, long requestId, String action, TransportRequest request, TransportRequestOptions options)
Transport
implementation once a request has been sentvoid onResponseSent(long requestId, String action, TransportResponse response, TransportResponseOptions options)
void onResponseSent(long requestId, String action, Throwable t)
TransportResponseHandler onResponseReceived(long requestId)
void onRequestReceived(long requestId, String action)
TransportRequestHandler handler(String action, Version version)
void raiseNodeConnected(DiscoveryNode node)
void raiseNodeDisconnected(DiscoveryNode node)
Copyright © 2009–2015. All rights reserved.