Package org.springframework.messaging.tcp

Interface TcpOperations<P>

Type Parameters:
P - the type of payload for inbound and outbound messages
All Known Implementing Classes:
ReactorNetty2TcpClient, ReactorNettyTcpClient
public interface TcpOperations<P>
A contract for establishing TCP connections.
Since:
4.0
Author:
Rossen Stoyanchev

  • Method Details

    • connectAsync

      CompletableFuture<Void> connectAsync(TcpConnectionHandler<P> connectionHandler)
      Open a new connection.
      Parameters:
      connectionHandler - a handler to manage the connection
      Returns:
      a CompletableFuture that can be used to determine when and if the connection is successfully established
      Since:
      6.0

    • connectAsync

      CompletableFuture<Void> connectAsync(TcpConnectionHandler<P> connectionHandler, ReconnectStrategy reconnectStrategy)
      Open a new connection and a strategy for reconnecting if the connection fails.
      Parameters:
      connectionHandler - a handler to manage the connection
      reconnectStrategy - a strategy for reconnecting
      Returns:
      a CompletableFuture that can be used to determine when and if the initial connection is successfully established
      Since:
      6.0

    • shutdownAsync

      CompletableFuture<Void> shutdownAsync()
      Shut down and close any open connections.
      Returns:
      a CompletableFuture that can be used to determine when and if the connection is successfully closed
      Since:
      6.0