インターフェース ReactivePubSubCommands
public interface ReactivePubSubCommands
Redis Pub/Sub コマンドはリアクティブインフラストラクチャを使用して実行されます。
- 導入:
- 2.1
- 作成者:
- Mark Paluch, Christoph Strobl
メソッドのサマリー
修飾子と型メソッド説明default reactor.core.publisher.Mono<ReactiveSubscription>
この接続のサブスクリプションを作成します。reactor.core.publisher.Mono<ReactiveSubscription>
createSubscription
(SubscriptionListener subscriptionListener) この接続のサブスクリプションを作成します。reactor.core.publisher.Mono<VoidSE>
pSubscribe
(ByteBufferSE... patterns) 指定されたpatterns
に一致するすべてのチャネルへの接続をサブスクライブします。default reactor.core.publisher.Mono<LongSE>
publish
(ByteBufferSE channel, ByteBufferSE message) 指定されたmessage
を指定されたchannel
に公開します。reactor.core.publisher.Flux<LongSE>
publish
(org.reactivestreams.Publisher<ReactiveSubscription.ChannelMessage<ByteBufferSE, ByteBufferSE>> messageStream) 指定されたメッセージをappropriate channels
に公開します。reactor.core.publisher.Mono<VoidSE>
subscribe
(ByteBufferSE... channels) 指定されたchannels
への接続をサブスクライブします。
メソッドの詳細
createSubscription
この接続のサブスクリプションを作成します。接続には複数のReactiveSubscription
を含めることができます。createSubscription(SubscriptionListener)
を使用して、サブスクリプションが完了したときに通知を受け取ります。- 戻り値:
- サブスクリプション。
createSubscription
reactor.core.publisher.Mono<ReactiveSubscription> createSubscription(SubscriptionListener subscriptionListener) この接続のサブスクリプションを作成します。接続には複数のReactiveSubscription
を含めることができます。- パラメーター:
subscriptionListener
- サブスクリプションの確認をリッスンするサブスクリプションリスナー。- 戻り値:
- サブスクリプション。
- 導入:
- 2.6
publish
指定されたmessage
を指定されたchannel
に公開します。- パラメーター:
channel
- 公開するチャネル。null であってはなりません。message
- 公開するメッセージ。null であってはなりません。- 戻り値:
- メッセージを受信したクライアントの数。
- 関連事項:
publish
reactor.core.publisher.Flux<LongSE> publish(org.reactivestreams.Publisher<ReactiveSubscription.ChannelMessage<ByteBufferSE, ByteBufferSE>> messageStream) 指定されたメッセージをappropriate channels
に公開します。- パラメーター:
messageStream
- 公開するメッセージ。null であってはなりません。- 戻り値:
- メッセージを受信したクライアントの数。
- 関連事項:
subscribe
指定されたchannels
への接続をサブスクライブします。サブスクライブすると、接続はリスニングモードになり、他のチャネルにサブスクライブするか、サブスクライブを解除することしかできません。接続がサブスクライブ解除されるまで、他のコマンドは受け入れられません。Flux
をキャンセルすると、channels
の購読が解除されることに注意してください。- パラメーター:
channels
- チャネル名は null であってはなりません。- 関連事項:
pSubscribe
指定されたpatterns
に一致するすべてのチャネルへの接続をサブスクライブします。サブスクライブすると、接続はリスニングモードになり、他のチャネルにサブスクライブするか、サブスクライブを解除することしかできません。接続がサブスクライブ解除されるまで、他のコマンドは受け入れられません。Flux
をキャンセルすると、patterns
の購読が解除されることに注意してください。- パラメーター:
patterns
- チャネル名パターン。null であってはなりません。- 関連事項: