Package eu.vstoyanov.natsy.jetstream
Class JetStreamConfig
-
- All Implemented Interfaces:
public final class JetStreamConfigConfiguration for JetStream operations
-
-
Field Summary
Fields Modifier and Type Field Description private final Stringdomainprivate final DurationrequestTimeoutprivate final LongmaxWaitMillisprivate final StringstreamPrefixprivate final RetentionPolicydefaultRetentionPolicyprivate final StorageTypedefaultStorageTypeprivate final IntegerdefaultReplicasprivate final DurationdefaultAckWaitprivate final IntegerdefaultMaxDeliverprivate final ReplayPolicydefaultReplayPolicy
-
Method Summary
Modifier and Type Method Description final StringgetDomain()JetStream domain name for multi-tenancy final DurationgetRequestTimeout()Request timeout for JetStream API calls final LonggetMaxWaitMillis()Maximum wait time in milliseconds for pull consumers final StringgetStreamPrefix()Optional prefix for stream names final RetentionPolicygetDefaultRetentionPolicy()Default retention policy for streams final StorageTypegetDefaultStorageType()Default storage type for streams final IntegergetDefaultReplicas()Default number of replicas for streams final DurationgetDefaultAckWait()Default acknowledgment wait time for consumers final IntegergetDefaultMaxDeliver()Default maximum delivery attempts (-1 for unlimited) final ReplayPolicygetDefaultReplayPolicy()Default replay policy for consumers -
-
Method Detail
-
getRequestTimeout
final Duration getRequestTimeout()
Request timeout for JetStream API calls
-
getMaxWaitMillis
final Long getMaxWaitMillis()
Maximum wait time in milliseconds for pull consumers
-
getStreamPrefix
final String getStreamPrefix()
Optional prefix for stream names
-
getDefaultRetentionPolicy
final RetentionPolicy getDefaultRetentionPolicy()
Default retention policy for streams
-
getDefaultStorageType
final StorageType getDefaultStorageType()
Default storage type for streams
-
getDefaultReplicas
final Integer getDefaultReplicas()
Default number of replicas for streams
-
getDefaultAckWait
final Duration getDefaultAckWait()
Default acknowledgment wait time for consumers
-
getDefaultMaxDeliver
final Integer getDefaultMaxDeliver()
Default maximum delivery attempts (-1 for unlimited)
-
getDefaultReplayPolicy
final ReplayPolicy getDefaultReplayPolicy()
Default replay policy for consumers
-
-
-
-