インターフェース ReactivePubSubCommands

方法の詳細

• createSubscription

  default reactor.core.publisher.Mono<ReactiveSubscription> createSubscription()

  この接続のサブスクリプションを作成します。接続には複数の ReactiveSubscription を含めることができます。

  createSubscription(SubscriptionListener) を使用して、サブスクリプションが完了したときに通知を受け取ります。

  戻り値:

  サブスクリプション。

• createSubscription

  reactor.core.publisher.Mono<ReactiveSubscription> createSubscription(SubscriptionListener subscriptionListener)

  この接続のサブスクリプションを作成します。接続には複数の ReactiveSubscription を含めることができます。

  パラメーター:

  subscriptionListener - サブスクリプションの確認をリッスンするサブスクリプションリスナー。

  戻り値:

  サブスクリプション。

  導入:

  2.6

• publish

  default reactor.core.publisher.Mono<LongSE> publish(ByteBufferSE channel, ByteBufferSE message)

  指定された message を指定された channel に公開します。

  パラメーター:

  channel - 公開するチャネル。null であってはなりません。

  message - 公開するメッセージ。null であってはなりません。

  戻り値:

  メッセージを受信したクライアントの数。

  関連事項:

  • Redis ドキュメント: PUBLISH

• publish

  reactor.core.publisher.Flux<LongSE> publish(org.reactivestreams.Publisher<ReactiveSubscription.ChannelMessage<ByteBufferSE,ByteBufferSE>> messageStream)

  指定されたメッセージを appropriate channels に公開します。

  パラメーター:

  messageStream - 公開するメッセージ。null であってはなりません。

  戻り値:

  メッセージを受信したクライアントの数。

  関連事項:

  • Redis ドキュメント: PUBLISH

• subscribe

  reactor.core.publisher.Mono<VoidSE> subscribe(ByteBufferSE... channels)

  指定された channels への接続をサブスクライブします。サブスクライブすると、接続はリスニングモードになり、他のチャネルにサブスクライブするか、サブスクライブを解除することしかできません。接続がサブスクライブ解除されるまで、他のコマンドは受け入れられません。

  Flux をキャンセルすると、channels の購読が解除されることに注意してください。

  パラメーター:

  channels - チャネル名は null であってはなりません。

  関連事項:

  • Redis ドキュメント: SUBSCRIBE

• pSubscribe

  reactor.core.publisher.Mono<VoidSE> pSubscribe(ByteBufferSE... patterns)

  指定された patterns に一致するすべてのチャネルへの接続をサブスクライブします。サブスクライブすると、接続はリスニングモードになり、他のチャネルにサブスクライブするか、サブスクライブを解除することしかできません。接続がサブスクライブ解除されるまで、他のコマンドは受け入れられません。

  Flux をキャンセルすると、patterns の購読が解除されることに注意してください。

  パラメーター:

  patterns - チャネル名パターン。null であってはなりません。

  関連事項:

  • Redis ドキュメント: PSUBSCRIBE