Package org.springframework.rabbit.stream.config

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 Summary

Constructors

Constructor	Description
SuperStream(String name, int partitions)	Create a Super Stream with the provided parameters.
SuperStream(String name, int partitions, BiFunction<String,Integer,List<String>> routingKeyStrategy)	Create a Super Stream with the provided parameters.

Method Summary

Methods inherited from class org.springframework.amqp.core.Declarables

getDeclarables, getDeclarablesByType, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

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.