java.lang.Object
- com.eventstore.dbclient.AbstractPersistentSubscriptionSettingsBuilder<T,TSettings>

Direct Known Subclasses:

CreatePersistentSubscriptionToAllOptions, CreatePersistentSubscriptionToStreamOptions, PersistentSubscriptionSettingsBuilder, PersistentSubscriptionToAllSettingsBuilder, UpdatePersistentSubscriptionToAllOptions, UpdatePersistentSubscriptionToStreamOptions
```
public class AbstractPersistentSubscriptionSettingsBuilder<T,TSettings extends PersistentSubscriptionSettings>
extends java.lang.Object
```

Field Summary

Fields
Modifier and Type	Field	Description
`protected java.lang.Long`	`deadline`
`protected com.eventstore.dbclient.OperationKind`	`kind`
`protected ConnectionMetadata`	`metadata`
`protected TSettings`	`settings`

Constructor Summary

Constructors
Constructor Description

AbstractPersistentSubscriptionSettingsBuilder(TSettings settings)

Method Summary

All Methods Instance Methods Concrete Methods Deprecated Methods
Modifier and Type	Method	Description
`T`	`authenticated(UserCredentials credentials)`
`T`	`checkpointAfter(java.time.Duration value)`	The amount of time to try to checkpoint after.
`T`	`checkpointAfterInMs(int value)`	The amount of time in milliseconds to try to checkpoint after.
`T`	`checkpointLowerBound(int value)`	The minimum number of messages to process before a checkpoint may be written.
`T`	`checkpointUpperBound(int value)`	The maximum number of messages not checkpointed before forcing a checkpoint.
`T`	`consumerStrategy(ConsumerStrategy strategy)`	The strategy to use for distributing events to client consumers.
`T`	`deadline(long durationInMs)`
`T`	`disableExtraStatistics()`	Disable tracking of latency statistics on this subscription.
`T`	`disableLinkResolution()`	Deprecated. prefer `notResolveLinkTos()`
`T`	`enableExtraStatistics()`	Enable tracking of latency statistics on this subscription.
`T`	`enableLinkResolution()`	Deprecated. prefer `resolveLinkTos()`
`T`	`extraStatistics(boolean value)`	Whether to track latency statistics on this subscription.
`UserCredentials`	`getCredentials()`
`java.lang.Long`	`getDeadline()`
`com.eventstore.dbclient.OperationKind`	`getKind()`
`io.grpc.Metadata`	`getMetadata()`
`TSettings`	`getSettings()`
`java.lang.String`	`getUserCredentials()`
`boolean`	`hasUserCredentials()`
`T`	`historyBufferSize(int value)`	The number of events to cache when catching up.
`boolean`	`isLeaderRequired()`
`T`	`liveBufferSize(int value)`	The size of the buffer (in-memory) listening to live messages as they happen before paging occurs.
`T`	`maxCheckpointCount(int value)`	Deprecated. prefer `checkpointUpperBound(int)`
`T`	`maxRetryCount(int value)`	The maximum number of retries (due to timeout) before a message is considered to be parked.
`T`	`maxSubscriberCount(int value)`	The maximum number of subscribers allowed.
`T`	`messageTimeout(java.time.Duration value)`	The amount of time after which to consider a message as timed out and retried.
`T`	`messageTimeoutInMs(int value)`	The amount of time in milliseconds after which to consider a message as timed out and retried.
`T`	`minCheckpointCount(int value)`	Deprecated. prefer `checkpointLowerBound(int)`
`T`	`namedConsumerStrategy(java.lang.String value)`	The strategy to use for distributing events to client consumers.
`T`	`notRequireLeader()`
`T`	`notResolveLinkTos()`	Don't resolve linkTo events to their linked events.
`T`	`readBatchSize(int value)`	The number of events read at a time when catching up.
`T`	`requiresLeader()`
`T`	`requiresLeader(boolean value)`
`T`	`resolveLinks(boolean value)`	Deprecated. prefer `resolveLinkTos(boolean)`
`T`	`resolveLinkTos()`	Resolve linkTo events to their linked events.
`T`	`resolveLinkTos(boolean value)`	Whether the subscription should resolve linkTo events to their linked events.

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

- Field Detail
  - settings
```
protected TSettings extends PersistentSubscriptionSettings settings
```
  - metadata
```
protected final ConnectionMetadata metadata
```
  - deadline
```
protected java.lang.Long deadline
```
  - kind
```
protected com.eventstore.dbclient.OperationKind kind
```
- Constructor Detail
  - AbstractPersistentSubscriptionSettingsBuilder
```
public AbstractPersistentSubscriptionSettingsBuilder(TSettings settings)
```
- Method Detail
  - enableLinkResolution
```
@Deprecated
public T enableLinkResolution()
```
    Deprecated.
    prefer resolveLinkTos()
  - disableLinkResolution
```
@Deprecated
public T disableLinkResolution()
```
    Deprecated.
    prefer notResolveLinkTos()
  - resolveLinks
```
@Deprecated
public T resolveLinks(boolean value)
```
    Deprecated.
    prefer resolveLinkTos(boolean)
  - resolveLinkTos
```
public T resolveLinkTos(boolean value)
```
    Whether the subscription should resolve linkTo events to their linked events. Default: false.
  - resolveLinkTos
```
public T resolveLinkTos()
```
    Resolve linkTo events to their linked events.
  - notResolveLinkTos
```
public T notResolveLinkTos()
```
    Don't resolve linkTo events to their linked events.
  - enableExtraStatistics
```
public T enableExtraStatistics()
```
    Enable tracking of latency statistics on this subscription.
  - disableExtraStatistics
```
public T disableExtraStatistics()
```
    Disable tracking of latency statistics on this subscription.
  - extraStatistics
```
public T extraStatistics(boolean value)
```
    Whether to track latency statistics on this subscription. Default: false.
  - checkpointAfter
```
public T checkpointAfter(java.time.Duration value)
```
    The amount of time to try to checkpoint after. Default: 2 seconds.
  - checkpointAfterInMs
```
public T checkpointAfterInMs(int value)
```
    The amount of time in milliseconds to try to checkpoint after. Default: 2 seconds.
  - historyBufferSize
```
public T historyBufferSize(int value)
```
    The number of events to cache when catching up. Default: 500.
  - liveBufferSize
```
public T liveBufferSize(int value)
```
    The size of the buffer (in-memory) listening to live messages as they happen before paging occurs. Default: 500.
  - maxCheckpointCount
```
@Deprecated
public T maxCheckpointCount(int value)
```
    Deprecated.
    prefer checkpointUpperBound(int)
  - checkpointUpperBound
```
public T checkpointUpperBound(int value)
```
    The maximum number of messages not checkpointed before forcing a checkpoint. Default: 1000.
  - minCheckpointCount
```
@Deprecated
public T minCheckpointCount(int value)
```
    Deprecated.
    prefer checkpointLowerBound(int)
  - checkpointLowerBound
```
public T checkpointLowerBound(int value)
```
    The minimum number of messages to process before a checkpoint may be written. Default: 10.
  - maxSubscriberCount
```
public T maxSubscriberCount(int value)
```
    The maximum number of subscribers allowed. Default: 0 (Unbounded).
  - maxRetryCount
```
public T maxRetryCount(int value)
```
    The maximum number of retries (due to timeout) before a message is considered to be parked. Default: 10.
  - messageTimeout
```
public T messageTimeout(java.time.Duration value)
```
    The amount of time after which to consider a message as timed out and retried. Default: 30 seconds.
  - messageTimeoutInMs
```
public T messageTimeoutInMs(int value)
```
    The amount of time in milliseconds after which to consider a message as timed out and retried. Default: 30 seconds.
  - readBatchSize
```
public T readBatchSize(int value)
```
    The number of events read at a time when catching up. Default: 20.
  - consumerStrategy
```
public T consumerStrategy(ConsumerStrategy strategy)
```
    The strategy to use for distributing events to client consumers.
  - namedConsumerStrategy
```
public T namedConsumerStrategy(java.lang.String value)
```
    The strategy to use for distributing events to client consumers.
  - getSettings
```
public TSettings getSettings()
```
  - getMetadata
```
public io.grpc.Metadata getMetadata()
```
  - hasUserCredentials
```
public boolean hasUserCredentials()
```
  - getUserCredentials
```
public java.lang.String getUserCredentials()
```
  - authenticated
```
public T authenticated(UserCredentials credentials)
```
  - requiresLeader
```
public T requiresLeader()
```
  - notRequireLeader
```
public T notRequireLeader()
```
  - requiresLeader
```
public T requiresLeader(boolean value)
```
  - deadline
```
public T deadline(long durationInMs)
```
  - getDeadline
```
public java.lang.Long getDeadline()
```
  - getKind
```
public com.eventstore.dbclient.OperationKind getKind()
```
  - isLeaderRequired
```
public boolean isLeaderRequired()
```
  - getCredentials
```
public UserCredentials getCredentials()
```

Class AbstractPersistentSubscriptionSettingsBuilder<T,​TSettings extends PersistentSubscriptionSettings>

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Field Detail

settings

metadata

deadline

kind

Constructor Detail

AbstractPersistentSubscriptionSettingsBuilder

Method Detail

enableLinkResolution

disableLinkResolution

resolveLinks

resolveLinkTos

resolveLinkTos

notResolveLinkTos

enableExtraStatistics

disableExtraStatistics

extraStatistics

checkpointAfter

checkpointAfterInMs

historyBufferSize

liveBufferSize

maxCheckpointCount

checkpointUpperBound

minCheckpointCount

checkpointLowerBound

maxSubscriberCount

maxRetryCount

messageTimeout

messageTimeoutInMs

readBatchSize

consumerStrategy

namedConsumerStrategy

getSettings

getMetadata

hasUserCredentials

getUserCredentials

authenticated

requiresLeader

notRequireLeader

requiresLeader

deadline

getDeadline

getKind

isLeaderRequired

getCredentials

Class AbstractPersistentSubscriptionSettingsBuilder<T,TSettings extends PersistentSubscriptionSettings>