インターフェースの使用
org.springframework.data.redis.connection.ReactiveSubscription.Message
ReactiveSubscription.Message を使用するパッケージ
パッケージ
説明
さまざまな Redis ' ドライバー '/libraries と対話するための低レベルの抽象化を提供する接続パッケージ。
Redis を Spring の概念と統合するためのコアパッケージ。
Redis メッセージリスナー / pubsub コンテナー機能の基本パッケージ
org.springframework.data.redis.connection 内の ReactiveSubscription.Message 使用
修飾子と型クラス説明static classRedis チャネルメッセージの値オブジェクト。static classパターンサブスクリプションから受信した Redis チャネルメッセージの値オブジェクト。型 ReactiveSubscription.Message の引数を持つ型を返す org.springframework.data.redis.connection のメソッドorg.springframework.data.redis.core 内の ReactiveSubscription.Message 使用
型 ReactiveSubscription.Message の引数を持つ型を返す org.springframework.data.redis.core のメソッド修飾子と型メソッド説明Flux<? extends ReactiveSubscription.Message<StringSE, V>> Flux<? extends ReactiveSubscription.Message<StringSE, V>> default Flux<? extends ReactiveSubscription.Message<StringSE, V>> ReactiveRedisOperations.listenToChannel(StringSE... channels) 指定された Redischannelsをサブスクライブし、それらに対して受信したmessagesを発行します。default Mono<Flux<? extends ReactiveSubscription.Message<StringSE, V>>> ReactiveRedisOperations.listenToChannelLater(StringSE... channels) 指定された Redischannelsをサブスクライブし、それらに対して受信したmessagesを発行します。Mono<Flux<? extends ReactiveSubscription.Message<StringSE, V>>> ReactiveRedisOperations.listenToLater(Topic... topics) Mono<Flux<? extends ReactiveSubscription.Message<StringSE, V>>> ReactiveRedisTemplate.listenToLater(Topic... topics) default Flux<? extends ReactiveSubscription.Message<StringSE, V>> ReactiveRedisOperations.listenToPattern(StringSE... patterns) 指定されたpatternに一致する Redis チャネルをサブスクライブし、それらに対して受信したmessagesを発行します。default Mono<Flux<? extends ReactiveSubscription.Message<StringSE, V>>> ReactiveRedisOperations.listenToPatternLater(StringSE... patterns) 指定されたpatternに一致する Redis チャネルをサブスクライブし、それらに対して受信したmessagesを発行します。org.springframework.data.redis.listener 内の ReactiveSubscription.Message 使用
型 ReactiveSubscription.Message の引数を持つ型を返す org.springframework.data.redis.listener のメソッド修飾子と型メソッド説明ReactiveRedisMessageListenerContainer.receive(IterableSE<? extends Topic> topics, SubscriptionListener subscriptionListener) 1 つ以上のTopicをサブスクライブし、ReactiveSubscription.ChannelMessageのストリームを受信します。<C,B> Flux <ReactiveSubscription.Message<C, B>> ReactiveRedisMessageListenerContainer.receive(IterableSE<? extends Topic> topics, RedisSerializationContext.SerializationPair<C> channelSerializer, RedisSerializationContext.SerializationPair<B> messageSerializer) 1 つ以上のTopicをサブスクライブし、ReactiveSubscription.ChannelMessageのストリームを受信します。<C,B> Flux <ReactiveSubscription.Message<C, B>> ReactiveRedisMessageListenerContainer.receive(IterableSE<? extends Topic> topics, RedisSerializationContext.SerializationPair<C> channelSerializer, RedisSerializationContext.SerializationPair<B> messageSerializer, SubscriptionListener subscriptionListener) 1 つ以上のTopicをサブスクライブし、ReactiveSubscription.ChannelMessageのストリームを受信します。ReactiveRedisMessageListenerContainer.receive(ChannelTopic... channelTopics) 1 つ以上のChannelTopicをサブスクライブし、ReactiveSubscription.ChannelMessageのストリームを受信します。<C,B> Mono <Flux<ReactiveSubscription.Message<C, B>>> ReactiveRedisMessageListenerContainer.receiveLater(IterableSE<? extends Topic> topics, RedisSerializationContext.SerializationPair<C> channelSerializer, RedisSerializationContext.SerializationPair<B> messageSerializer) 1 つ以上のTopicをサブスクライブし、ReactiveSubscription.ChannelMessageのストリームを受信します。ReactiveRedisMessageListenerContainer.receiveLater(ChannelTopic... channelTopics)