Class AbstractPersistentSubscriptionSettingsBuilder<T>

    • 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()
    • Method Detail

      • enableLinkResolution

        @Deprecated
        public T enableLinkResolution()
        Deprecated.
      • disableLinkResolution

        @Deprecated
        public T disableLinkResolution()
        Deprecated.
      • 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.
      • checkPointUpperBound

        public T checkPointUpperBound​(int value)
        The maximum number of messages not checkpointed before forcing a checkpoint. Default: 1000.
      • 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.