Class SuperStream

java.lang.Object
org.springframework.amqp.core.Declarables
org.springframework.rabbit.stream.config.SuperStream

public class SuperStream extends Declarables
Create Super Stream Topology Declarables.
Since:
3.0
Author:
Gary Russell
  • Constructor Details

    • SuperStream

      public SuperStream(String name, int partitions)
      Create a Super Stream with the provided parameters.
      Parameters:
      name - the stream name.
      partitions - the number of partitions.
    • SuperStream

      public SuperStream(String name, int partitions, BiFunction<String,Integer,List<String>> routingKeyStrategy)
      Create a Super Stream with the provided parameters.
      Parameters:
      name - the stream name.
      partitions - the number of partitions.
      routingKeyStrategy - a strategy to determine routing keys to use for the partitions. The first parameter is the queue name, the second the number of partitions, the returned list must have a size equal to the partitions.