インターフェースの使用
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 のメソッド修飾子と型メソッド説明reactor.core.publisher.Flux<ReactiveSubscription.Message<ByteBufferSE,ByteBufferSE>> ReactiveSubscription.receive()messagesを発行するメッセージストリームを取得します。org.springframework.data.redis.core 内の ReactiveSubscription.Message 使用
型 ReactiveSubscription.Message の引数を持つ型を返す org.springframework.data.redis.core のメソッド修飾子と型メソッド説明reactor.core.publisher.Flux<? extends ReactiveSubscription.Message<StringSE,V>> reactor.core.publisher.Flux<? extends ReactiveSubscription.Message<StringSE,V>> default reactor.core.publisher.Flux<? extends ReactiveSubscription.Message<StringSE,V>> ReactiveRedisOperations.listenToChannel(StringSE... channels) 指定された Redischannelsをサブスクライブし、それらに対して受信したmessagesを発行します。default reactor.core.publisher.Mono<reactor.core.publisher.Flux<? extends ReactiveSubscription.Message<StringSE,V>>> ReactiveRedisOperations.listenToChannelLater(StringSE... channels) 指定された Redischannelsをサブスクライブし、それらに対して受信したmessagesを発行します。reactor.core.publisher.Mono<reactor.core.publisher.Flux<? extends ReactiveSubscription.Message<StringSE,V>>> ReactiveRedisOperations.listenToLater(Topic... topics) reactor.core.publisher.Mono<reactor.core.publisher.Flux<? extends ReactiveSubscription.Message<StringSE,V>>> ReactiveRedisTemplate.listenToLater(Topic... topics) default reactor.core.publisher.Flux<? extends ReactiveSubscription.Message<StringSE,V>> ReactiveRedisOperations.listenToPattern(StringSE... patterns) 指定されたpatternに一致する Redis チャネルをサブスクライブし、それらに対して受信したmessagesを発行します。default reactor.core.publisher.Mono<reactor.core.publisher.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 のメソッド修飾子と型メソッド説明reactor.core.publisher.Flux<ReactiveSubscription.Message<StringSE,StringSE>> ReactiveRedisMessageListenerContainer.receive(IterableSE<? extends Topic> topics, SubscriptionListener subscriptionListener) 1 つ以上のTopicをサブスクライブし、ReactiveSubscription.ChannelMessageのストリームを受信します。<C,B> reactor.core.publisher.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> reactor.core.publisher.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のストリームを受信します。reactor.core.publisher.Flux<ReactiveSubscription.Message<StringSE,StringSE>> ReactiveRedisMessageListenerContainer.receive(ChannelTopic... channelTopics) 1 つ以上のChannelTopicをサブスクライブし、ReactiveSubscription.ChannelMessageのストリームを受信します。<C,B> reactor.core.publisher.Mono<reactor.core.publisher.Flux<ReactiveSubscription.Message<C, B>>> ReactiveRedisMessageListenerContainer.receiveLater(IterableSE<? extends Topic> topics, RedisSerializationContext.SerializationPair<C> channelSerializer, RedisSerializationContext.SerializationPair<B> messageSerializer) 1 つ以上のTopicをサブスクライブし、ReactiveSubscription.ChannelMessageのストリームを受信します。reactor.core.publisher.Mono<reactor.core.publisher.Flux<ReactiveSubscription.Message<StringSE,StringSE>>> ReactiveRedisMessageListenerContainer.receiveLater(ChannelTopic... channelTopics)