Package com.eventstore.dbclient

Class PersistentSubscriptionSettingsBuilder

java.lang.Object

com.eventstore.dbclient.AbstractPersistentSubscriptionSettingsBuilder<PersistentSubscriptionSettingsBuilder,PersistentSubscriptionToStreamSettings>

com.eventstore.dbclient.PersistentSubscriptionSettingsBuilder

public class PersistentSubscriptionSettingsBuilder
extends AbstractPersistentSubscriptionSettingsBuilder<PersistentSubscriptionSettingsBuilder,PersistentSubscriptionToStreamSettings>

Field Summary

Fields

Modifier and Type	Field	Description
protected java.lang.Long	deadline
protected com.eventstore.dbclient.OperationKind	kind
protected ConnectionMetadata	metadata

Fields inherited from class com.eventstore.dbclient.AbstractPersistentSubscriptionSettingsBuilder

settings

Constructor Summary

Constructors

Constructor	Description
PersistentSubscriptionSettingsBuilder()
PersistentSubscriptionSettingsBuilder(PersistentSubscriptionToStreamSettings settings)

Method Summary

Modifier and Type	Method	Description
T	authenticated(UserCredentials credentials)
PersistentSubscriptionSettings	build()
T	deadline(long durationInMs)
PersistentSubscriptionSettingsBuilder	fromEnd()
PersistentSubscriptionSettingsBuilder	fromStart()
PersistentSubscriptionSettingsBuilder	fromStreamStart()	Deprecated. prefer fromStart()
UserCredentials	getCredentials()
java.lang.Long	getDeadline()
com.eventstore.dbclient.OperationKind	getKind()
io.grpc.Metadata	getMetadata()
java.lang.String	getUserCredentials()
boolean	hasUserCredentials()
boolean	isLeaderRequired()
T	notRequireLeader()
T	requiresLeader()
T	requiresLeader(boolean value)
PersistentSubscriptionSettingsBuilder	revision(long value)	Deprecated. prefer startFrom(long)
PersistentSubscriptionSettingsBuilder	startFrom(long value)	The exclusive position in the stream or transaction file the subscription should start from.
PersistentSubscriptionSettingsBuilder	startFrom(StreamPosition<java.lang.Long> value)	The exclusive position in the stream or transaction file the subscription should start from.

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

metadata

protected final ConnectionMetadata metadata

deadline

protected java.lang.Long deadline

kind

protected com.eventstore.dbclient.OperationKind kind

Constructor Detail

PersistentSubscriptionSettingsBuilder

public PersistentSubscriptionSettingsBuilder()

PersistentSubscriptionSettingsBuilder

public PersistentSubscriptionSettingsBuilder(PersistentSubscriptionToStreamSettings settings)

Method Detail

build

public PersistentSubscriptionSettings build()

fromStart

public PersistentSubscriptionSettingsBuilder fromStart()

fromEnd

public PersistentSubscriptionSettingsBuilder fromEnd()

startFrom

public PersistentSubscriptionSettingsBuilder startFrom(long value)

The exclusive position in the stream or transaction file the subscription should start from. Default: End of stream.

startFrom

public PersistentSubscriptionSettingsBuilder startFrom(StreamPosition<java.lang.Long> value)

The exclusive position in the stream or transaction file the subscription should start from. Default: End of stream.

revision

@Deprecated
public PersistentSubscriptionSettingsBuilder revision(long value)

Deprecated.

prefer startFrom(long)

fromStreamStart

@Deprecated
public PersistentSubscriptionSettingsBuilder fromStreamStart()

Deprecated.

prefer fromStart()

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()