インターフェース ReactiveSubscription

public interface ReactiveSubscription
リアクティブインフラストラクチャを使用した Redis チャネルのサブスクリプション。ReactiveSubscription を使用すると、channels および patterns にサブスクライブできます。この ReactiveSubscription に登録されているチャネルとパターンのメッセージのみを送信する ReactiveSubscription.ChannelMessage stream へのアクセスを提供します。

リアクティブ Redis 接続には、複数のサブスクリプションを含めることができます。2 つ以上のサブスクリプションが同じターゲット（チャネル / パターン）にサブスクライブし、一方がサブスクライブを解除した場合、Redis が Pub/Sub サブスクリプションを処理した方法により、もう一方はターゲットのメッセージを受信しなくなります。

導入:
2.1
作成者:
Mark Paluch, Christoph Strobl

  • 方法の詳細

    • subscribe

      Mono<VoidSE> subscribe(ByteBufferSE... channels)
      channels をサブスクライブし、これらを現在のサブスクリプションに追加します。
      パラメーター:
      channels - チャネル名。空であってはなりません。
      戻り値:
      チャンネルサブスクリプションが登録されると完了する空の Mono。

    • pSubscribe

      Mono<VoidSE> pSubscribe(ByteBufferSE... patterns)
      チャネル patterns をサブスクライブし、これらを現在のサブスクリプションに追加します。
      パラメーター:
      patterns - チャネルパターン。空であってはなりません。
      戻り値:
      パターンサブスクリプションが登録されると完了する空の Mono。

    • unsubscribe

      Mono<VoidSE> unsubscribe()
      すべての channels の現在のサブスクリプションをキャンセルします。
      戻り値:
      チャネルサブスクリプションが登録解除されると完了する空の Mono。

    • unsubscribe

      Mono<VoidSE> unsubscribe(ByteBufferSE... channels)
      指定されたすべてのチャネルの現在のサブスクリプションをキャンセルします。
      パラメーター:
      channels - チャネル名。空であってはなりません。
      戻り値:
      チャネルサブスクリプションが登録解除されると完了する空の Mono。

    • pUnsubscribe

      Mono<VoidSE> pUnsubscribe()
      getPatterns() パターンに一致するすべてのチャネルのサブスクリプションをキャンセルします。}。
      戻り値:
      パターンのサブスクリプションが登録解除されると完了する空の Mono。

    • pUnsubscribe

      Mono<VoidSE> pUnsubscribe(ByteBufferSE... patterns)
      指定されたパターンに一致するすべてのチャネルのサブスクリプションをキャンセルします。
      パラメーター:
      patterns - 空であってはなりません。
      戻り値:
      パターンのサブスクリプションが登録解除されると完了する空の Mono。

    • getChannels

      SetSE<ByteBufferSE> getChannels()
      このサブスクリプションの（名前付き）チャネルを返します。
      戻り値:
      名前付きチャネルの SetSE。

    • getPatterns

      SetSE<ByteBufferSE> getPatterns()
      このサブスクリプションのチャネルパターンを返します。
      戻り値:
      チャネルパターンの SetSE。

    • receive

      Flux<ReactiveSubscription.Message<ByteBufferSE, ByteBufferSE>> receive()
      messages を発行するメッセージストリームを取得します。結果のメッセージストリームには、サブスクライブおよび登録された channels および patterns のメッセージのみが含まれます。

      ストリームのパブリッシュは ConnectableFlux を使用してストリームをホットシーケンスに変換します。需要がない場合、送信は一時停止されます。その間に受信されたメッセージはバッファリングされます。このストリームは、すべてのサブスクライバーが登録解除するか、この Subscription が is terminated になった場合に終了します。

      戻り値:
      Flux が ReactiveSubscription.Message ストリームを送信します。

    • cancel

      Mono<VoidSE> cancel()
      すべての channels および patterns のサブスクライブを解除し、すべてのアクティブな message streams の終了をリクエストします。アクティブなストリームは CancellationExceptionSE で終了します。
      戻り値:
      終了が完了すると完了する Mono。