Interface TransportMessageListener

All Known Implementing Classes:
TransportService

public interface TransportMessageListener
  • Field Summary

    Fields 
    Modifier and Type Field Description
    static TransportMessageListener NOOP_LISTENER  
  • Method Summary

    Modifier and Type Method Description
    default void onRequestReceived​(long requestId, java.lang.String action)
    Called once a request is received
    default void onRequestSent​(DiscoveryNode node, long requestId, java.lang.String action, TransportRequest request, TransportRequestOptions finalOptions)
    Called for every request sent to a server after the request has been passed to the underlying network implementation
    default void onResponseReceived​(long requestId, Transport.ResponseContext context)
    Called for every response received
    default void onResponseSent​(long requestId, java.lang.String action, java.lang.Exception error)
    Called for every failed action response after the response has been passed to the underlying network implementation.
    default void onResponseSent​(long requestId, java.lang.String action, TransportResponse response)
    Called for every action response sent after the response has been passed to the underlying network implementation.
  • Field Details

  • Method Details

    • onRequestReceived

      default void onRequestReceived​(long requestId, java.lang.String action)
      Called once a request is received
      Parameters:
      requestId - the internal request ID
      action - the request action
    • onResponseSent

      default void onResponseSent​(long requestId, java.lang.String action, TransportResponse response)
      Called for every action response sent after the response has been passed to the underlying network implementation.
      Parameters:
      requestId - the request ID (unique per client)
      action - the request action
      response - the response send
    • onResponseSent

      default void onResponseSent​(long requestId, java.lang.String action, java.lang.Exception error)
      Called for every failed action response after the response has been passed to the underlying network implementation.
      Parameters:
      requestId - the request ID (unique per client)
      action - the request action
      error - the error sent back to the caller
    • onRequestSent

      default void onRequestSent​(DiscoveryNode node, long requestId, java.lang.String action, TransportRequest request, TransportRequestOptions finalOptions)
      Called for every request sent to a server after the request has been passed to the underlying network implementation
      Parameters:
      node - the node the request was sent to
      requestId - the internal request id
      action - the action name
      request - the actual request
      finalOptions - the request options
    • onResponseReceived

      default void onResponseReceived​(long requestId, Transport.ResponseContext context)
      Called for every response received
      Parameters:
      requestId - the request id for this reponse
      context - the response context or null if the context was already processed ie. due to a timeout.