Package com.eventstore.dbclient

Class PersistentSubscriptionConfig

  • public class PersistentSubscriptionConfig
extends java.lang.Object

    • Constructor Detail

      • PersistentSubscriptionConfig

        public PersistentSubscriptionConfig()

    • Method Detail

      • setResolveLinktos

        public void setResolveLinktos​(boolean resolveLinktos)

      • setStartFrom

        public void setStartFrom​(long startFrom)

      • setMessageTimeoutMilliseconds

        public void setMessageTimeoutMilliseconds​(long messageTimeoutMilliseconds)

      • setExtraStatistics

        public void setExtraStatistics​(boolean extraStatistics)

      • setMaxRetryCount

        public void setMaxRetryCount​(long maxRetryCount)

      • setLiveBufferSize

        public void setLiveBufferSize​(long liveBufferSize)

      • setBufferSize

        public void setBufferSize​(long bufferSize)

      • setReadBatchSize

        public void setReadBatchSize​(long readBatchSize)

      • setPreferRoundRobin

        public void setPreferRoundRobin​(boolean preferRoundRobin)

      • setCheckPointAfterMilliseconds

        public void setCheckPointAfterMilliseconds​(long checkPointAfterMilliseconds)

      • setMinCheckPointCount

        public void setMinCheckPointCount​(long minCheckPointCount)

      • setMaxCheckPointCount

        public void setMaxCheckPointCount​(long maxCheckPointCount)

      • setMaxSubscriberCount

        public void setMaxSubscriberCount​(long maxSubscriberCount)

      • setNamedConsumerStrategy

        public void setNamedConsumerStrategy​(ConsumerStrategy namedConsumerStrategy)

      • isResolveLinktos

        public boolean isResolveLinktos()

      • getStartFrom

        public long getStartFrom()

      • getMessageTimeoutMilliseconds

        public long getMessageTimeoutMilliseconds()

      • isExtraStatistics

        public boolean isExtraStatistics()

      • getMaxRetryCount

        public long getMaxRetryCount()

      • getLiveBufferSize

        public long getLiveBufferSize()

      • getBufferSize

        public long getBufferSize()

      • getReadBatchSize

        public long getReadBatchSize()

      • isPreferRoundRobin

        public boolean isPreferRoundRobin()

      • getCheckPointAfterMilliseconds

        public long getCheckPointAfterMilliseconds()

      • getMinCheckPointCount

        public long getMinCheckPointCount()

      • getMaxCheckPointCount

        public long getMaxCheckPointCount()

      • getMaxSubscriberCount

        public long getMaxSubscriberCount()