Method Detail

• transportServiceAdapter

  void transportServiceAdapter(TransportServiceAdapter service)

• boundAddress

  BoundTransportAddress boundAddress()

  The address the transport is bound on.

• profileBoundAddresses

  Map<String,BoundTransportAddress> profileBoundAddresses()

  Further profile bound addresses

  Returns:

  Should return null if transport does not support profiles, otherwise a map with name of profile and its bound transport address

• addressesFromString

  TransportAddress[] addressesFromString(String address)
                                  throws Exception

  Returns an address from its string representation.

  Throws:

  Exception

• addressSupported

  boolean addressSupported(Class<? extends TransportAddress> address)

  Is the address type supported.

• nodeConnected

  boolean nodeConnected(DiscoveryNode node)

  Returns true if the node is connected.

• connectToNode

  void connectToNode(DiscoveryNode node)
              throws ConnectTransportException

  Connects to the given node, if already connected, does nothing.

  Throws:

  ConnectTransportException

• connectToNodeLight

  void connectToNodeLight(DiscoveryNode node)
                   throws ConnectTransportException

  Connects to a node in a light manner. Used when just connecting for ping and then disconnecting.

  Throws:

  ConnectTransportException

• disconnectFromNode

  void disconnectFromNode(DiscoveryNode node)

  Disconnected from the given node, if not connected, will do nothing.

• sendRequest

  void sendRequest(DiscoveryNode node,
                   long requestId,
                   String action,
                   TransportRequest request,
                   TransportRequestOptions options)
            throws IOException,
                   TransportException

  Sends the request to the node.

  Throws:

  IOException

  TransportException

• serverOpen

  long serverOpen()

  Returns count of currently open connections