Method Detail

• received

  void received(long size)

• sent

  void sent(long size)

• onRequestSent

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

  called by the Transport implementation once a request has been sent

• onResponseSent

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

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

• onResponseSent

  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

• onResponseReceived

  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). Returns the appropriate response handler or null if not found.

• onRequestReceived

  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)

• handler

  TransportRequestHandler handler(String action,
                                  Version version)

• raiseNodeConnected

  void raiseNodeConnected(DiscoveryNode node)

• raiseNodeDisconnected

  void raiseNodeDisconnected(DiscoveryNode node)

• action

  String action(String action,
                Version version)