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 String`	`apiPrefix`
`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()`	How long a JetStream API call waits for the server, including a publish waiting for its ackA publish is awaited against this deadline, but the future jnats actually uses is cleaned up on eu.vstoyanov.natsy.KlientConfigBuilder.requestCleanupInterval.
`final Unit`	`setRequestTimeout(Duration value)`	How long a JetStream API call waits for the server, including a publish waiting for its ackA publish is awaited against this deadline, but the future jnats actually uses is cleaned up on eu.vstoyanov.natsy.KlientConfigBuilder.requestCleanupInterval.
`final String`	`getApiPrefix()`	Non-default JetStream API subject prefix, as `JetStreamOptions.prefix`This is the subject every JetStream API call is addressed to, which is how a client reaches JetStream in another account.
`final Unit`	`setApiPrefix(String value)`	Non-default JetStream API subject prefix, as `JetStreamOptions.prefix`This is the subject every JetStream API call is addressed to, which is how a client reaches JetStream in another account.
`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()
```
    How long a JetStream API call waits for the server, including a publish waiting for its ack
    A publish is awaited against this deadline, but the future jnats actually uses is cleaned up on eu.vstoyanov.natsy.KlientConfigBuilder.requestCleanupInterval. natsy raises that interval to cover this timeout so the two agree.
  - setRequestTimeout
```
 final Unit setRequestTimeout(Duration value)
```
    How long a JetStream API call waits for the server, including a publish waiting for its ack
    A publish is awaited against this deadline, but the future jnats actually uses is cleaned up on eu.vstoyanov.natsy.KlientConfigBuilder.requestCleanupInterval. natsy raises that interval to cover this timeout so the two agree.
  - getApiPrefix
```
 final String getApiPrefix()
```
    Non-default JetStream API subject prefix, as JetStreamOptions.prefix
    This is the subject every JetStream API call is addressed to, which is how a client reaches JetStream in another account. Set it only when the server expects one - pointing it at a prefix nothing serves leaves every API call unanswered.
  - setApiPrefix
```
 final Unit setApiPrefix(String value)
```
    Non-default JetStream API subject prefix, as JetStreamOptions.prefix
    This is the subject every JetStream API call is addressed to, which is how a client reaches JetStream in another account. Set it only when the server expects one - pointing it at a prefix nothing serves leaves every API call unanswered.
  - 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

getApiPrefix

setApiPrefix

getDefaultRetentionPolicy

setDefaultRetentionPolicy

getDefaultStorageType

setDefaultStorageType

getDefaultReplicas

setDefaultReplicas

getDefaultAckWait

setDefaultAckWait

getDefaultMaxDeliver

setDefaultMaxDeliver

getDefaultReplayPolicy

setDefaultReplayPolicy