パッケージ org.springframework.messaging.tcp.reactor

クラス ReactorNettyTcpConnection<P>

java.lang.ObjectSE
org.springframework.messaging.tcp.reactor.ReactorNettyTcpConnection<P>
型パラメーター:
P - 送信メッセージのペイロードの型
実装されたすべてのインターフェース:
CloseableSE、AutoCloseableSE、TcpConnection<P>
public class ReactorNettyTcpConnection<P> extends ObjectSE implements TcpConnection<P>
Reactor Netty ベースの TcpConnection の実装。
導入:
5.0
作成者:
Rossen Stoyanchev

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

    • ReactorNettyTcpConnection

      public ReactorNettyTcpConnection(reactor.netty.NettyInbound inbound, reactor.netty.NettyOutbound outbound, ReactorNettyCodec<P> codec, reactor.core.publisher.Sinks.Empty<VoidSE> completionSink)

  • メソッドの詳細

    • sendAsync

      public CompletableFutureSE<VoidSE> sendAsync(Message<P> message)
      インターフェースからコピーされた説明: TcpConnection
      指定されたメッセージを送信します。
      次で指定:
      インターフェース TcpConnection<P> の sendAsync 
      パラメーター:
      message - メッセージ
      戻り値:
      メッセージがいつ正常に送信されたかを判断するために使用できる CompletableFuture

    • onReadInactivity

      public void onReadInactivity(RunnableSE runnable, long inactivityDuration)
      インターフェースからコピーされた説明: TcpConnection
      一定の読み取り非アクティブ期間の後に呼び出すタスクを登録します。
      次で指定:
      インターフェース TcpConnection<P> の onReadInactivity 
      パラメーター:
      runnable - 呼び出すタスク
      inactivityDuration - ミリ秒単位の非アクティブ時間

    • onWriteInactivity

      public void onWriteInactivity(RunnableSE runnable, long inactivityDuration)
      インターフェースからコピーされた説明: TcpConnection
      一定期間の書き込み非アクティブ後に呼び出されるタスクを登録します。
      次で指定:
      インターフェース TcpConnection<P> の onWriteInactivity 
      パラメーター:
      runnable - 呼び出すタスク
      inactivityDuration - ミリ秒単位の非アクティブ時間

    • close

      public void close()
      インターフェースからコピーされた説明: TcpConnection
      接続を閉じる。
      次で指定:
      インターフェース AutoCloseableSE の close 
      次で指定:
      インターフェース CloseableSE の close 
      次で指定:
      インターフェース TcpConnection<P> の close 

    • toString

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