Package com.eventstore.dbclient

Class AbstractPersistentSubscriptionSettings<T>

java.lang.Object

com.eventstore.dbclient.AbstractPersistentSubscriptionSettings<T>

Direct Known Subclasses:

PersistentSubscriptionSettings, PersistentSubscriptionToAllSettings

public abstract class AbstractPersistentSubscriptionSettings<T>
extends java.lang.Object

Constructor Summary

Constructors

Constructor	Description
AbstractPersistentSubscriptionSettings(int checkpointAfterMs, boolean extraStatistics, boolean resolveLinks, int historyBufferSize, int liveBufferSize, int checkPointUpperBound, int maxRetryCount, int maxSubscriberCount, int messageTimeoutMs, int minCheckpointCount, int readBatchSize, java.lang.String consumerStrategyName)

Method Summary

Modifier and Type	Method	Description
java.time.Duration	getCheckpointAfter()	The amount of time to try to checkpoint after.
int	getCheckpointAfterMs()	The amount of time in milliseconds to try to checkpoint after.
int	getCheckPointLowerBound()	The minimum number of messages to process before a checkpoint may be written.
int	getCheckPointUpperBound()	The maximum number of messages not checkpointed before forcing a checkpoint.
java.lang.String	getConsumerStrategyName()	The strategy to use for distributing events to client consumers.
int	getHistoryBufferSize()	The number of events to cache when catching up.
int	getLiveBufferSize()	The size of the buffer (in-memory) listening to live messages as they happen before paging occurs.
int	getMaxCheckpointCount()	Deprecated. prefer getCheckPointUpperBound()
int	getMaxRetryCount()	The maximum number of retries (due to timeout) before a message is considered to be parked.
int	getMaxSubscriberCount()	The maximum number of subscribers allowed.
java.time.Duration	getMessageTimeout()	The amount of time after which to consider a message as timed out and retried.
int	getMessageTimeoutMs()	The amount of time in milliseconds after which to consider a message as timed out and retried.
int	getMinCheckpointCount()	Deprecated. prefer getCheckPointLowerBound()
int	getReadBatchSize()	The number of events read at a time when catching up.
ConsumerStrategy	getStrategy()	Deprecated. prefer getConsumerStrategyName()
boolean	isExtraStatistics()	Whether to track latency statistics on this subscription.
boolean	isResolveLinks()	Deprecated. prefer shouldResolveLinkTos()
boolean	shouldResolveLinkTos()	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

Constructor Detail

AbstractPersistentSubscriptionSettings

public AbstractPersistentSubscriptionSettings(int checkpointAfterMs,
                                              boolean extraStatistics,
                                              boolean resolveLinks,
                                              int historyBufferSize,
                                              int liveBufferSize,
                                              int checkPointUpperBound,
                                              int maxRetryCount,
                                              int maxSubscriberCount,
                                              int messageTimeoutMs,
                                              int minCheckpointCount,
                                              int readBatchSize,
                                              java.lang.String consumerStrategyName)

Method Detail

getCheckpointAfterMs

public int getCheckpointAfterMs()

The amount of time in milliseconds to try to checkpoint after.

getCheckpointAfter

public java.time.Duration getCheckpointAfter()

The amount of time to try to checkpoint after.

isExtraStatistics

public boolean isExtraStatistics()

Whether to track latency statistics on this subscription.

isResolveLinks

public boolean isResolveLinks()

Deprecated.

prefer shouldResolveLinkTos()

shouldResolveLinkTos

public boolean shouldResolveLinkTos()

Whether the subscription should resolve linkTo events to their linked events.

getHistoryBufferSize

public int getHistoryBufferSize()

The number of events to cache when catching up. Default 500.

getLiveBufferSize

public int getLiveBufferSize()

The size of the buffer (in-memory) listening to live messages as they happen before paging occurs. Default 500.

getMaxCheckpointCount

@Deprecated
public int getMaxCheckpointCount()

Deprecated.

prefer getCheckPointUpperBound()

getCheckPointUpperBound

public int getCheckPointUpperBound()

The maximum number of messages not checkpointed before forcing a checkpoint.

getMaxRetryCount

public int getMaxRetryCount()

The maximum number of retries (due to timeout) before a message is considered to be parked.

getMaxSubscriberCount

public int getMaxSubscriberCount()

The maximum number of subscribers allowed.

getMessageTimeout

public java.time.Duration getMessageTimeout()

The amount of time after which to consider a message as timed out and retried.

getMessageTimeoutMs

public int getMessageTimeoutMs()

The amount of time in milliseconds after which to consider a message as timed out and retried.

getMinCheckpointCount

@Deprecated
public int getMinCheckpointCount()

Deprecated.

prefer getCheckPointLowerBound()

getCheckPointLowerBound

public int getCheckPointLowerBound()

The minimum number of messages to process before a checkpoint may be written.

getReadBatchSize

public int getReadBatchSize()

The number of events read at a time when catching up.

getStrategy

@Deprecated
public ConsumerStrategy getStrategy()
                             throws java.lang.Exception

Deprecated.

prefer getConsumerStrategyName()

Throws:

java.lang.Exception

getConsumerStrategyName

public java.lang.String getConsumerStrategyName()

The strategy to use for distributing events to client consumers.