クラス ReactiveRedisMessageListenerContainer

メソッドの詳細

• destroy

  public void destroy()

  次で指定:

  インターフェース DisposableBean の destroy 

• destroyLater

  public reactor.core.publisher.Mono<VoidSE> destroyLater()

  戻り値:

  Mono シグナリングコンテナーの終了。

• getActiveSubscriptions

  public CollectionSE<ReactiveSubscription> getActiveSubscriptions()

  現在アクティブな subscriptions を返します。

  戻り値:

  アクティブな ReactiveSubscription の SetSE

• receive

  public reactor.core.publisher.Flux<ReactiveSubscription.Message<StringSE,StringSE>> receive(ChannelTopic... channelTopics)

  1 つ以上の ChannelTopic をサブスクライブし、ReactiveSubscription.ChannelMessage のストリームを受信します。メッセージとチャネル名は StringSE として扱われます。メッセージストリームは、Redis チャネルに遅延サブスクライブし、Subscription が cancelled の場合はサブスクライブを解除します。

  パラメーター:

  channelTopics - サブスクライブするチャネル。

  戻り値:

  メッセージストリーム。

  例外:

  InvalidDataAccessApiUsageException - channelTopics が空の場合。

  関連事項:

  • receive(Iterable, SerializationPair, SerializationPair)

• receiveLater

  public reactor.core.publisher.Mono<reactor.core.publisher.Flux<ReactiveSubscription.Message<StringSE,StringSE>>> receiveLater(ChannelTopic... channelTopics)

  1 つ以上の ChannelTopic をサブスクライブし、返された Mono が完了すると、ReactiveSubscription.ChannelMessage のストリームを受信します。メッセージとチャネル名は StringSE として扱われます。メッセージストリームは Redis チャネルに遅延サブスクライブし、内部 Subscription が cancelled の場合はサブスクライブを解除します。

  返された Mono は、接続が指定された topics にサブスクライブされると完了します。返された Mono をキャンセルすると、接続がサブスクライブ状態のままになる可能性があることに注意してください。

  パラメーター:

  channelTopics - サブスクライブするチャネル。

  戻り値:

  メッセージストリーム。

  例外:

  InvalidDataAccessApiUsageException - channelTopics が空の場合。

  導入:

  2.6

• receive

  public reactor.core.publisher.Flux<ReactiveSubscription.PatternMessage<StringSE,StringSE,StringSE>> receive(PatternTopic... patternTopics)

  1 つ以上の PatternTopic をサブスクライブし、ReactiveSubscription.PatternMessage のストリームを受信します。メッセージ、パターン、チャネル名は StringSE として扱われます。メッセージストリームは、Redis チャネルに遅延サブスクライブし、Subscription が cancelled の場合はサブスクライブを解除します。

  パラメーター:

  patternTopics - サブスクライブするチャネル。

  戻り値:

  メッセージストリーム。

  例外:

  InvalidDataAccessApiUsageException - patternTopics が空の場合。

  関連事項:

  • receive(Iterable, SerializationPair, SerializationPair)

• receiveLater

  public reactor.core.publisher.Mono<reactor.core.publisher.Flux<ReactiveSubscription.PatternMessage<StringSE,StringSE,StringSE>>> receiveLater(PatternTopic... patternTopics)

  1 つ以上の PatternTopic をサブスクライブし、返された Mono が完了すると、ReactiveSubscription.PatternMessage のストリームを受信します。メッセージ、パターン、チャネル名は StringSE として扱われます。メッセージストリームは Redis チャネルに遅延サブスクライブし、内部 Subscription が cancelled の場合はサブスクライブを解除します。

  返された Mono は、接続が指定された topics にサブスクライブされると完了します。返された Mono をキャンセルすると、接続がサブスクライブ状態のままになる可能性があることに注意してください。

  パラメーター:

  patternTopics - サブスクライブするチャネル。

  戻り値:

  メッセージストリーム。

  例外:

  InvalidDataAccessApiUsageException - patternTopics が空の場合。

  導入:

  2.6

• receive

  public reactor.core.publisher.Flux<ReactiveSubscription.Message<StringSE,StringSE>> receive(IterableSE<? extends Topic> topics, SubscriptionListener subscriptionListener)

  1 つ以上の Topic をサブスクライブし、ReactiveSubscription.ChannelMessage のストリームを受信します。パターンにサブスクライブしている場合、ストリームには ReactiveSubscription.PatternMessage が含まれている可能性があります。メッセージおよびチャネル名は、指定された channelSerializer および messageSerializer を使用して直列化 / 逆直列化されます。メッセージストリームは、Redis チャネルに遅延してサブスクライブし、Subscription が cancelled の場合はサブスクライブを解除します。

  パラメーター:

  topics - サブスクライブするチャネル / パターン。

  subscriptionListener - サブスクリプション / サブスクリプション解除の通知を受信するリスナー。

  戻り値:

  メッセージストリーム。

  例外:

  InvalidDataAccessApiUsageException - patternTopics が空の場合。

  導入:

  2.6

  関連事項:

  • receive(Iterable, SerializationPair, SerializationPair)

• receive

  public <C, B> reactor.core.publisher.Flux<ReactiveSubscription.Message<C,B>> receive(IterableSE<? extends Topic> topics, RedisSerializationContext.SerializationPair<C> channelSerializer, RedisSerializationContext.SerializationPair<B> messageSerializer)

  1 つ以上の Topic をサブスクライブし、ReactiveSubscription.ChannelMessage のストリームを受信します。パターンにサブスクライブしている場合、ストリームには ReactiveSubscription.PatternMessage が含まれている可能性があります。メッセージおよびチャネル名は、指定された channelSerializer および messageSerializer を使用して直列化 / 逆直列化されます。メッセージストリームは、Redis チャネルに遅延してサブスクライブし、Subscription が cancelled の場合はサブスクライブを解除します。

  パラメーター:

  topics - サブスクライブするチャネル / パターン。

  戻り値:

  メッセージストリーム。

  例外:

  InvalidDataAccessApiUsageException - topics が空の場合。

  関連事項:

  • receive(Iterable, SerializationPair, SerializationPair)

• receive

  public <C, B> reactor.core.publisher.Flux<ReactiveSubscription.Message<C,B>> receive(IterableSE<? extends Topic> topics, RedisSerializationContext.SerializationPair<C> channelSerializer, RedisSerializationContext.SerializationPair<B> messageSerializer, SubscriptionListener subscriptionListener)

  1 つ以上の Topic をサブスクライブし、ReactiveSubscription.ChannelMessage のストリームを受信します。パターンにサブスクライブしている場合、ストリームには ReactiveSubscription.PatternMessage が含まれている可能性があります。メッセージおよびチャネル名は、指定された channelSerializer および messageSerializer を使用して直列化 / 逆直列化されます。メッセージストリームは、Redis チャネルに遅延してサブスクライブし、Subscription が cancelled の場合はサブスクライブを解除します。SubscriptionListener は、サブスクリプション / サブスクリプション解除時に通知され、同期に使用できます。

  パラメーター:

  topics - サブスクライブするチャネル。

  channelSerializer - チャネル / パターン名をデコードするための直列化ペア。

  messageSerializer - メッセージ本文をデコードするための直列化ペア。

  subscriptionListener - サブスクリプション / サブスクリプション解除の通知を受信するリスナー。

  戻り値:

  メッセージストリーム。

  例外:

  InvalidDataAccessApiUsageException - topics が空の場合。

  導入:

  2.6

  関連事項:

  • receive(Iterable, SerializationPair, SerializationPair)

• receiveLater

  public <C, B> reactor.core.publisher.Mono<reactor.core.publisher.Flux<ReactiveSubscription.Message<C,B>>> receiveLater(IterableSE<? extends Topic> topics, RedisSerializationContext.SerializationPair<C> channelSerializer, RedisSerializationContext.SerializationPair<B> messageSerializer)

  1 つ以上の Topic をサブスクライブし、ReactiveSubscription.ChannelMessage のストリームを受信します。返された Mono は、接続が指定された topics にサブスクライブされると完了します。返された Mono をキャンセルすると、接続がサブスクライブ状態のままになる可能性があることに注意してください。

  パラメーター:

  topics - サブスクライブするチャネル。

  channelSerializer - チャネル / パターン名をデコードするための直列化ペア。

  messageSerializer - メッセージ本文をデコードするための直列化ペア。

  戻り値:

  メッセージストリーム。

  例外:

  InvalidDataAccessApiUsageException - topics が空の場合。

  導入:

  2.6