All Implemented Interfaces:


public final class StreamConfigBuilder

Builder for JetStream stream configuration

Nested Class Summary

Nested Classes
Modifier and Type	Class	Description

Field Summary

Fields
Modifier and Type	Field	Description
`private List<String>`	`subjects`
`private RetentionPolicy`	`retentionPolicy`
`private Integer`	`maxConsumers`
`private Long`	`maxMessages`
`private Long`	`maxBytes`
`private Duration`	`maxAge`
`private Integer`	`maxMsgSize`
`private StorageType`	`storageType`
`private Integer`	`replicas`
`private Boolean`	`noAck`
`private Duration`	`duplicateWindow`
`private DiscardPolicy`	`discardPolicy`
`private String`	`description`
`private Long`	`maxMessagesPerSubject`

Constructor Summary

Constructors
Constructor	Description
`StreamConfigBuilder()`

Enum Constant Summary

Enum Constants
Enum Constant	Description

Method Summary

Modifier and Type	Method	Description
`final List<String>`	`getSubjects()`	List of subjects this stream listens to Supports wildcards (e.g., "orders.*", "payments.>")
`final Unit`	`setSubjects(List<String> <set-?>)`	List of subjects this stream listens to Supports wildcards (e.g., "orders.*", "payments.>")
`final RetentionPolicy`	`getRetentionPolicy()`	Retention policy for the stream
`final Unit`	`setRetentionPolicy(RetentionPolicy <set-?>)`	Retention policy for the stream
`final Integer`	`getMaxConsumers()`	Maximum number of consumers allowed on this stream (-1 for unlimited)
`final Unit`	`setMaxConsumers(Integer <set-?>)`	Maximum number of consumers allowed on this stream (-1 for unlimited)
`final Long`	`getMaxMessages()`	Maximum number of messages to retain (-1 for unlimited)
`final Unit`	`setMaxMessages(Long <set-?>)`	Maximum number of messages to retain (-1 for unlimited)
`final Long`	`getMaxBytes()`	Maximum total bytes to retain (-1 for unlimited)
`final Unit`	`setMaxBytes(Long <set-?>)`	Maximum total bytes to retain (-1 for unlimited)
`final Duration`	`getMaxAge()`	Maximum age of messages to retain (Duration.
`final Unit`	`setMaxAge(Duration <set-?>)`	Maximum age of messages to retain (Duration.
`final Integer`	`getMaxMsgSize()`	Maximum size of a single message (-1 for unlimited)
`final Unit`	`setMaxMsgSize(Integer <set-?>)`	Maximum size of a single message (-1 for unlimited)
`final StorageType`	`getStorageType()`	Storage type for the stream
`final Unit`	`setStorageType(StorageType <set-?>)`	Storage type for the stream
`final Integer`	`getReplicas()`	Number of replicas for the stream (1-5)
`final Unit`	`setReplicas(Integer <set-?>)`	Number of replicas for the stream (1-5)
`final Boolean`	`getNoAck()`	Disable acknowledgments (used for fire-and-forget scenarios)
`final Unit`	`setNoAck(Boolean <set-?>)`	Disable acknowledgments (used for fire-and-forget scenarios)
`final Duration`	`getDuplicateWindow()`	Window within which to track duplicate messages
`final Unit`	`setDuplicateWindow(Duration <set-?>)`	Window within which to track duplicate messages
`final DiscardPolicy`	`getDiscardPolicy()`	Discard policy when limits are reached
`final Unit`	`setDiscardPolicy(DiscardPolicy <set-?>)`	Discard policy when limits are reached
`final String`	`getDescription()`	Description of the stream
`final Unit`	`setDescription(String <set-?>)`	Description of the stream
`final Long`	`getMaxMessagesPerSubject()`	Maximum messages per subject (-1 for unlimited)
`final Unit`	`setMaxMessagesPerSubject(Long <set-?>)`	Maximum messages per subject (-1 for unlimited)
`final Unit`	`placement(Function1<PlacementBuilder, Unit> block)`	Configure placement for the stream
`final Unit`	`mirror(Function1<StreamSourceBuilder, Unit> block)`	Configure mirror to replicate another stream
`final Unit`	`source(Function1<StreamSourceBuilder, Unit> block)`	Add a source stream for aggregation

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Constructor Detail
  - StreamConfigBuilder
```
StreamConfigBuilder()
```
- Method Detail
  - getSubjects
```
 final List<String> getSubjects()
```
    List of subjects this stream listens to Supports wildcards (e.g., "orders.*", "payments.>")
  - setSubjects
```
 final Unit setSubjects(List<String> <set-?>)
```
    List of subjects this stream listens to Supports wildcards (e.g., "orders.*", "payments.>")
  - getRetentionPolicy
```
 final RetentionPolicy getRetentionPolicy()
```
    Retention policy for the stream
  - setRetentionPolicy
```
 final Unit setRetentionPolicy(RetentionPolicy <set-?>)
```
    Retention policy for the stream
  - getMaxConsumers
```
 final Integer getMaxConsumers()
```
    Maximum number of consumers allowed on this stream (-1 for unlimited)
  - setMaxConsumers
```
 final Unit setMaxConsumers(Integer <set-?>)
```
    Maximum number of consumers allowed on this stream (-1 for unlimited)
  - getMaxMessages
```
 final Long getMaxMessages()
```
    Maximum number of messages to retain (-1 for unlimited)
  - setMaxMessages
```
 final Unit setMaxMessages(Long <set-?>)
```
    Maximum number of messages to retain (-1 for unlimited)
  - getMaxBytes
```
 final Long getMaxBytes()
```
    Maximum total bytes to retain (-1 for unlimited)
  - setMaxBytes
```
 final Unit setMaxBytes(Long <set-?>)
```
    Maximum total bytes to retain (-1 for unlimited)
  - getMaxAge
```
 final Duration getMaxAge()
```
    Maximum age of messages to retain (Duration.ZERO for unlimited)
  - setMaxAge
```
 final Unit setMaxAge(Duration <set-?>)
```
    Maximum age of messages to retain (Duration.ZERO for unlimited)
  - getMaxMsgSize
```
 final Integer getMaxMsgSize()
```
    Maximum size of a single message (-1 for unlimited)
  - setMaxMsgSize
```
 final Unit setMaxMsgSize(Integer <set-?>)
```
    Maximum size of a single message (-1 for unlimited)
  - getStorageType
```
 final StorageType getStorageType()
```
    Storage type for the stream
  - setStorageType
```
 final Unit setStorageType(StorageType <set-?>)
```
    Storage type for the stream
  - getReplicas
```
 final Integer getReplicas()
```
    Number of replicas for the stream (1-5)
  - setReplicas
```
 final Unit setReplicas(Integer <set-?>)
```
    Number of replicas for the stream (1-5)
  - getNoAck
```
 final Boolean getNoAck()
```
    Disable acknowledgments (used for fire-and-forget scenarios)
  - setNoAck
```
 final Unit setNoAck(Boolean <set-?>)
```
    Disable acknowledgments (used for fire-and-forget scenarios)
  - getDuplicateWindow
```
 final Duration getDuplicateWindow()
```
    Window within which to track duplicate messages
  - setDuplicateWindow
```
 final Unit setDuplicateWindow(Duration <set-?>)
```
    Window within which to track duplicate messages
  - getDiscardPolicy
```
 final DiscardPolicy getDiscardPolicy()
```
    Discard policy when limits are reached
  - setDiscardPolicy
```
 final Unit setDiscardPolicy(DiscardPolicy <set-?>)
```
    Discard policy when limits are reached
  - getDescription
```
 final String getDescription()
```
    Description of the stream
  - setDescription
```
 final Unit setDescription(String <set-?>)
```
    Description of the stream
  - getMaxMessagesPerSubject
```
 final Long getMaxMessagesPerSubject()
```
    Maximum messages per subject (-1 for unlimited)
  - setMaxMessagesPerSubject
```
 final Unit setMaxMessagesPerSubject(Long <set-?>)
```
    Maximum messages per subject (-1 for unlimited)
  - placement
```
 final Unit placement(Function1<PlacementBuilder, Unit> block)
```
    Configure placement for the stream
  - mirror
```
 final Unit mirror(Function1<StreamSourceBuilder, Unit> block)
```
    Configure mirror to replicate another stream
  - source
```
 final Unit source(Function1<StreamSourceBuilder, Unit> block)
```
    Add a source stream for aggregation

Class StreamConfigBuilder

Nested Class Summary

Field Summary

Constructor Summary

Enum Constant Summary

Method Summary

Methods inherited from class java.lang.Object

Constructor Detail

StreamConfigBuilder

Method Detail

getSubjects

setSubjects

getRetentionPolicy

setRetentionPolicy

getMaxConsumers

setMaxConsumers

getMaxMessages

setMaxMessages

getMaxBytes

setMaxBytes

getMaxAge

setMaxAge

getMaxMsgSize

setMaxMsgSize

getStorageType

setStorageType

getReplicas

setReplicas

getNoAck

setNoAck

getDuplicateWindow

setDuplicateWindow

getDiscardPolicy

setDiscardPolicy

getDescription

setDescription

getMaxMessagesPerSubject

setMaxMessagesPerSubject

placement

mirror

source