クラス SuperStream

java.lang.ObjectSE
org.springframework.amqp.core.Declarables
org.springframework.rabbit.stream.config.SuperStream
public class SuperStream extends Declarables
スーパーストリームトポロジ Declarable を作成します。
導入:
3.0
作成者:
Gary Russell, Sergei Kurenchuk, Artem Bilan

  • コンストラクターの詳細

    • SuperStream

      public SuperStream(StringSE name, int partitions)
      指定されたパラメーターを使用してスーパーストリームを作成します。
      パラメーター:
      name - ストリーム名。
      partitions - パーティションの数。

    • SuperStream

      public SuperStream(StringSE name, int partitions, MapSE<StringSE,ObjectSE> arguments)
      指定されたパラメーターを使用してスーパーストリームを作成します。
      パラメーター:
      name - ストリーム名。
      partitions - パーティションの数。
      arguments - ストリーム引数
      導入:
      3.1

    • SuperStream

      public SuperStream(StringSE name, int partitions, BiFunctionSE<StringSE, IntegerSE, ListSE<StringSE>> routingKeyStrategy)
      指定されたパラメーターを使用してスーパーストリームを作成します。
      パラメーター:
      name - ストリーム名。
      partitions - パーティションの数。
      routingKeyStrategy - パーティションに使用するルーティングキーを決定する戦略。最初のパラメーターはキュー名、2 番目のパラメーターはパーティションの数です。返されるリストはパーティションと同じサイズでなければなりません。

    • SuperStream

      public SuperStream(StringSE name, int partitions, BiFunctionSE<StringSE, IntegerSE, ListSE<StringSE>> routingKeyStrategy, MapSE<StringSE,ObjectSE> arguments)
      指定されたパラメーターを使用してスーパーストリームを作成します。
      パラメーター:
      name - ストリーム名。
      partitions - パーティションの数。
      routingKeyStrategy - パーティションに使用するルーティングキーを決定する戦略。最初のパラメーターはキュー名、2 番目のパラメーターはパーティションの数です。返されるリストはパーティションと同じサイズでなければなりません。
      arguments - ストリーム引数
      導入:
      3.1