Package com.eventstore.dbclient
Class PersistentSubscriptionToAllSettingsBuilder
- java.lang.Object
-
- com.eventstore.dbclient.AbstractPersistentSubscriptionSettingsBuilder<PersistentSubscriptionToAllSettingsBuilder,PersistentSubscriptionToAllSettings>
-
- com.eventstore.dbclient.PersistentSubscriptionToAllSettingsBuilder
-
public class PersistentSubscriptionToAllSettingsBuilder extends AbstractPersistentSubscriptionSettingsBuilder<PersistentSubscriptionToAllSettingsBuilder,PersistentSubscriptionToAllSettings>
-
-
Field Summary
Fields Modifier and Type Field Description protected java.lang.Longdeadlineprotected com.eventstore.dbclient.OperationKindkindprotected ConnectionMetadatametadata-
Fields inherited from class com.eventstore.dbclient.AbstractPersistentSubscriptionSettingsBuilder
settings
-
-
Constructor Summary
Constructors Constructor Description PersistentSubscriptionToAllSettingsBuilder()PersistentSubscriptionToAllSettingsBuilder(PersistentSubscriptionToAllSettings settings)
-
Method Summary
-
Methods inherited from class com.eventstore.dbclient.AbstractPersistentSubscriptionSettingsBuilder
checkpointAfter, checkpointAfterInMs, checkpointLowerBound, checkpointUpperBound, consumerStrategy, disableExtraStatistics, disableLinkResolution, enableExtraStatistics, enableLinkResolution, extraStatistics, getSettings, historyBufferSize, liveBufferSize, maxCheckpointCount, maxRetryCount, maxSubscriberCount, messageTimeout, messageTimeoutInMs, minCheckpointCount, namedConsumerStrategy, notResolveLinkTos, readBatchSize, resolveLinks, resolveLinkTos, resolveLinkTos
-
-
-
-
Field Detail
-
metadata
protected final ConnectionMetadata metadata
-
deadline
protected java.lang.Long deadline
-
kind
protected com.eventstore.dbclient.OperationKind kind
-
-
Constructor Detail
-
PersistentSubscriptionToAllSettingsBuilder
public PersistentSubscriptionToAllSettingsBuilder()
-
PersistentSubscriptionToAllSettingsBuilder
public PersistentSubscriptionToAllSettingsBuilder(PersistentSubscriptionToAllSettings settings)
-
-
Method Detail
-
build
public PersistentSubscriptionSettings build()
-
fromStart
public PersistentSubscriptionToAllSettingsBuilder fromStart()
-
fromEnd
public PersistentSubscriptionToAllSettingsBuilder fromEnd()
-
startFrom
public PersistentSubscriptionToAllSettingsBuilder startFrom(long commitUnsigned, long prepareUnsigned)
The exclusive position in the stream or transaction file the subscription should start from. Default: End of stream.
-
startFrom
public PersistentSubscriptionToAllSettingsBuilder startFrom(Position value)
The exclusive position in the stream or transaction file the subscription should start from. Default: End of stream.
-
filter
public PersistentSubscriptionToAllSettingsBuilder filter(SubscriptionFilter filter)
-
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()
-
-