インターフェース ReactivePubSubCommands

メソッドの詳細

• createSubscription

  default Mono<ReactiveSubscription> createSubscription()

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

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

  戻り値:

  サブスクリプション。

• createSubscription

  Mono<ReactiveSubscription> createSubscription(SubscriptionListener subscriptionListener)

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

  パラメーター:

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

  戻り値:

  サブスクリプション。

  導入:

  2.6

• publish

  default Mono<LongSE> publish(ByteBufferSE channel, ByteBufferSE message)

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

  パラメーター:

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

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

  戻り値:

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

  関連事項:

  • Redis ドキュメント: PUBLISH

• publish

  Flux<LongSE> publish(Publisher<ReactiveSubscription.ChannelMessage<ByteBufferSE,ByteBufferSE>> messageStream)

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

  パラメーター:

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

  戻り値:

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

  関連事項:

  • Redis ドキュメント: PUBLISH

• subscribe

  Mono<VoidSE> subscribe(ByteBufferSE... channels)

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

  Flux をキャンセルすると、channels からも登録解除されることに注意してください。

  パラメーター:

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

  関連事項:

  • Redis ドキュメント: SUBSCRIBE

• pSubscribe

  Mono<VoidSE> pSubscribe(ByteBufferSE... patterns)

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

  Flux をキャンセルすると、patterns からも登録解除されることに注意してください。

  パラメーター:

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

  関連事項:

  • Redis ドキュメント: PSUBSCRIBE