All Implemented Interfaces:


public final class JetStreamConfigBuilder

Builder for JetStream configuration

Nested Class Summary

Nested Classes
Modifier and Type	Class	Description

Field Summary

Fields
Modifier and Type	Field	Description
`private String`	`domain`
`private Duration`	`requestTimeout`
`private Long`	`maxWaitMillis`
`private String`	`streamPrefix`
`private RetentionPolicy`	`defaultRetentionPolicy`
`private StorageType`	`defaultStorageType`
`private Integer`	`defaultReplicas`
`private Duration`	`defaultAckWait`
`private Integer`	`defaultMaxDeliver`
`private ReplayPolicy`	`defaultReplayPolicy`

Constructor Summary

Constructors
Constructor	Description
`JetStreamConfigBuilder()`

Enum Constant Summary

Enum Constants
Enum Constant	Description

Method Summary

Modifier and Type	Method	Description
`final String`	`getDomain()`	JetStream domain name for multi-tenancy
`final Unit`	`setDomain(String value)`	JetStream domain name for multi-tenancy
`final Duration`	`getRequestTimeout()`	Request timeout for JetStream API calls
`final Unit`	`setRequestTimeout(Duration value)`	Request timeout for JetStream API calls
`final Long`	`getMaxWaitMillis()`	Maximum wait time in milliseconds for pull consumers
`final Unit`	`setMaxWaitMillis(Long value)`	Maximum wait time in milliseconds for pull consumers
`final String`	`getStreamPrefix()`	Optional prefix for stream names
`final Unit`	`setStreamPrefix(String value)`	Optional prefix for stream names
`final RetentionPolicy`	`getDefaultRetentionPolicy()`	Default retention policy for streams
`final Unit`	`setDefaultRetentionPolicy(RetentionPolicy value)`	Default retention policy for streams
`final StorageType`	`getDefaultStorageType()`	Default storage type for streams
`final Unit`	`setDefaultStorageType(StorageType value)`	Default storage type for streams
`final Integer`	`getDefaultReplicas()`	Default number of replicas for streams
`final Unit`	`setDefaultReplicas(Integer value)`	Default number of replicas for streams
`final Duration`	`getDefaultAckWait()`	Default acknowledgment wait time for consumers
`final Unit`	`setDefaultAckWait(Duration value)`	Default acknowledgment wait time for consumers
`final Integer`	`getDefaultMaxDeliver()`	Default maximum delivery attempts (-1 for unlimited)
`final Unit`	`setDefaultMaxDeliver(Integer value)`	Default maximum delivery attempts (-1 for unlimited)
`final ReplayPolicy`	`getDefaultReplayPolicy()`	Default replay policy for consumers
`final Unit`	`setDefaultReplayPolicy(ReplayPolicy value)`	Default replay policy for consumers

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

- Constructor Detail
  - JetStreamConfigBuilder
```
JetStreamConfigBuilder()
```
- Method Detail
  - getDomain
```
 final String getDomain()
```
    JetStream domain name for multi-tenancy
  - setDomain
```
 final Unit setDomain(String value)
```
    JetStream domain name for multi-tenancy
  - getRequestTimeout
```
 final Duration getRequestTimeout()
```
    Request timeout for JetStream API calls
  - setRequestTimeout
```
 final Unit setRequestTimeout(Duration value)
```
    Request timeout for JetStream API calls
  - getMaxWaitMillis
```
 final Long getMaxWaitMillis()
```
    Maximum wait time in milliseconds for pull consumers
  - setMaxWaitMillis
```
 final Unit setMaxWaitMillis(Long value)
```
    Maximum wait time in milliseconds for pull consumers
  - getStreamPrefix
```
 final String getStreamPrefix()
```
    Optional prefix for stream names
  - setStreamPrefix
```
 final Unit setStreamPrefix(String value)
```
    Optional prefix for stream names
  - getDefaultRetentionPolicy
```
 final RetentionPolicy getDefaultRetentionPolicy()
```
    Default retention policy for streams
  - setDefaultRetentionPolicy
```
 final Unit setDefaultRetentionPolicy(RetentionPolicy value)
```
    Default retention policy for streams
  - getDefaultStorageType
```
 final StorageType getDefaultStorageType()
```
    Default storage type for streams
  - setDefaultStorageType
```
 final Unit setDefaultStorageType(StorageType value)
```
    Default storage type for streams
  - getDefaultReplicas
```
 final Integer getDefaultReplicas()
```
    Default number of replicas for streams
  - setDefaultReplicas
```
 final Unit setDefaultReplicas(Integer value)
```
    Default number of replicas for streams
  - getDefaultAckWait
```
 final Duration getDefaultAckWait()
```
    Default acknowledgment wait time for consumers
  - setDefaultAckWait
```
 final Unit setDefaultAckWait(Duration value)
```
    Default acknowledgment wait time for consumers
  - getDefaultMaxDeliver
```
 final Integer getDefaultMaxDeliver()
```
    Default maximum delivery attempts (-1 for unlimited)
  - setDefaultMaxDeliver
```
 final Unit setDefaultMaxDeliver(Integer value)
```
    Default maximum delivery attempts (-1 for unlimited)
  - getDefaultReplayPolicy
```
 final ReplayPolicy getDefaultReplayPolicy()
```
    Default replay policy for consumers
  - setDefaultReplayPolicy
```
 final Unit setDefaultReplayPolicy(ReplayPolicy value)
```
    Default replay policy for consumers

Class JetStreamConfigBuilder

Nested Class Summary

Field Summary

Constructor Summary

Enum Constant Summary

Method Summary

Methods inherited from class java.lang.Object

Constructor Detail

JetStreamConfigBuilder

Method Detail

getDomain

setDomain

getRequestTimeout

setRequestTimeout

getMaxWaitMillis

setMaxWaitMillis

getStreamPrefix

setStreamPrefix

getDefaultRetentionPolicy

setDefaultRetentionPolicy

getDefaultStorageType

setDefaultStorageType

getDefaultReplicas

setDefaultReplicas

getDefaultAckWait

setDefaultAckWait

getDefaultMaxDeliver

setDefaultMaxDeliver

getDefaultReplayPolicy

setDefaultReplayPolicy