Package com.eventstore.dbclient
Class AbstractPersistentSubscriptionSettingsBuilder<T>
- java.lang.Object
-
- com.eventstore.dbclient.AbstractPersistentSubscriptionSettingsBuilder<T>
-
- Direct Known Subclasses:
PersistentSubscriptionSettingsBuilder,PersistentSubscriptionToAllSettingsBuilder
public class AbstractPersistentSubscriptionSettingsBuilder<T> extends java.lang.Object
-
-
Field Summary
Fields Modifier and Type Field Description protected intcheckpointAfterMsprotected intcheckPointLowerBoundprotected intcheckPointUpperBoundprotected java.lang.StringconsumerStrategyNameprotected booleanextraStatisticsprotected inthistoryBufferSizeprotected intliveBufferSizeprotected intmaxRetryCountprotected intmaxSubscriberCountprotected intmessageTimeoutMsprotected intreadBatchSizeprotected booleanresolveLinkTos
-
Constructor Summary
Constructors Constructor Description AbstractPersistentSubscriptionSettingsBuilder()AbstractPersistentSubscriptionSettingsBuilder(AbstractPersistentSubscriptionSettings settings)
-
Method Summary
All Methods Instance Methods Concrete Methods Deprecated Methods Modifier and Type Method Description TcheckpointAfter(java.time.Duration value)The amount of time to try to checkpoint after.TcheckpointAfterInMs(int value)The amount of time in milliseconds to try to checkpoint after.TcheckPointLowerBound(int value)The minimum number of messages to process before a checkpoint may be written.TcheckPointUpperBound(int value)The maximum number of messages not checkpointed before forcing a checkpoint.TconsumerStrategy(ConsumerStrategy strategy)The strategy to use for distributing events to client consumers.TdisableExtraStatistics()Disable tracking of latency statistics on this subscription.TdisableLinkResolution()Deprecated.prefernotResolveLinkTos()TenableExtraStatistics()Enable tracking of latency statistics on this subscription.TenableLinkResolution()Deprecated.preferresolveLinkTos()TextraStatistics(boolean value)Whether to track latency statistics on this subscription.ThistoryBufferSize(int value)The number of events to cache when catching up.TliveBufferSize(int value)The size of the buffer (in-memory) listening to live messages as they happen before paging occurs.TmaxCheckpointCount(int value)Deprecated.prefercheckPointUpperBound(int)TmaxRetryCount(int value)The maximum number of retries (due to timeout) before a message is considered to be parked.TmaxSubscriberCount(int value)The maximum number of subscribers allowed.TmessageTimeout(java.time.Duration value)The amount of time after which to consider a message as timed out and retried.TmessageTimeoutInMs(int value)The amount of time in milliseconds after which to consider a message as timed out and retried.TminCheckpointCount(int value)Deprecated.prefercheckPointLowerBound(int)TnamedConsumerStrategy(java.lang.String value)The strategy to use for distributing events to client consumers.TnotResolveLinkTos()Don't resolve linkTo events to their linked events.TreadBatchSize(int value)The number of events read at a time when catching up.TresolveLinks(boolean value)Deprecated.preferresolveLinkTos(boolean)TresolveLinkTos()Resolve linkTo events to their linked events.TresolveLinkTos(boolean value)Whether the subscription should resolve linkTo events to their linked events.
-
-
-
Field Detail
-
checkpointAfterMs
protected int checkpointAfterMs
-
extraStatistics
protected boolean extraStatistics
-
resolveLinkTos
protected boolean resolveLinkTos
-
historyBufferSize
protected int historyBufferSize
-
liveBufferSize
protected int liveBufferSize
-
checkPointUpperBound
protected int checkPointUpperBound
-
maxRetryCount
protected int maxRetryCount
-
maxSubscriberCount
protected int maxSubscriberCount
-
messageTimeoutMs
protected int messageTimeoutMs
-
checkPointLowerBound
protected int checkPointLowerBound
-
readBatchSize
protected int readBatchSize
-
consumerStrategyName
protected java.lang.String consumerStrategyName
-
-
Constructor Detail
-
AbstractPersistentSubscriptionSettingsBuilder
public AbstractPersistentSubscriptionSettingsBuilder()
-
AbstractPersistentSubscriptionSettingsBuilder
public AbstractPersistentSubscriptionSettingsBuilder(AbstractPersistentSubscriptionSettings settings)
-
-
Method Detail
-
enableLinkResolution
@Deprecated public T enableLinkResolution()
Deprecated.preferresolveLinkTos()
-
disableLinkResolution
@Deprecated public T disableLinkResolution()
Deprecated.prefernotResolveLinkTos()
-
resolveLinks
@Deprecated public T resolveLinks(boolean value)
Deprecated.preferresolveLinkTos(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.prefercheckPointUpperBound(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.prefercheckPointLowerBound(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.
-
-