クラス ReactorNettyTcpStompClient

java.lang.ObjectSE
org.springframework.messaging.simp.stomp.StompClientSupport
org.springframework.messaging.simp.stomp.ReactorNettyTcpStompClient
public class ReactorNettyTcpStompClient extends StompClientSupport
ReactorNettyTcpClient で設定可能な STOMP over TCP クライアント。
導入:
5.0
作成者:
Rossen Stoyanchev

  • コンストラクターの詳細

    • ReactorNettyTcpStompClient

      public ReactorNettyTcpStompClient()
      ホスト "127.0.0.1" とポート 61613 を使用してインスタンスを作成します。

    • ReactorNettyTcpStompClient

      public ReactorNettyTcpStompClient(StringSE host, int port)
      指定されたホストとポートでインスタンスを作成します。
      パラメーター:
      host - ザホスト
      port - 港

    • ReactorNettyTcpStompClient

      public ReactorNettyTcpStompClient(TcpOperations<byte[]> tcpClient)
      事前構成された TCP クライアントでインスタンスを作成します。
      パラメーター:
      tcpClient - 使用するクライアント

  • メソッドの詳細

    • connectAsync

      public CompletableFutureSE<StompSession> connectAsync(StompSessionHandler handler)
      STOMP レベルで接続されている場合は、指定された StompSessionHandler を接続して通知します。
      パラメーター:
      handler - STOMP セッションのハンドラー
      戻り値:
      使用の準備ができたときにセッションにアクセスするための CompletableFuture
      導入:
      6.0

    • connectAsync

      public CompletableFutureSE<StompSession> connectAsync(@Nullable StompHeaders connectHeaders, StompSessionHandler handler)
      STOMP CONNECT フレームに使用するヘッダーを受け入れるオーバーロードバージョンの connectAsync(StompSessionHandler)。
      パラメーター:
      connectHeaders - CONNECT フレームに追加するヘッダー
      handler - STOMP セッションのハンドラー
      戻り値:
      使用の準備ができたときにセッションにアクセスするための CompletableFuture

    • shutdown

      public void shutdown()
      クライアントをシャットダウンし、リソースを解放します。

    • toString

      public StringSE toString()
      オーバーライド:
      クラス ObjectSE の toString