public class SubscribePersistentSubscriptionOptions
extends java.lang.Object
| Modifier and Type | Field and Description |
|---|---|
protected ConnectionMetadata |
metadata |
protected Timeouts |
timeouts |
| Modifier and Type | Method and Description |
|---|---|
T |
authenticated(UserCredentials credentials) |
static SubscribePersistentSubscriptionOptions |
get() |
int |
getBufferSize() |
io.grpc.Metadata |
getMetadata() |
Timeouts |
getTimeouts() |
boolean |
hasUserCredentials() |
T |
notRequireLeader() |
T |
requiresLeader() |
T |
requiresLeader(boolean value) |
SubscribePersistentSubscriptionOptions |
setBufferSize(int value) |
T |
timeouts(Timeouts timeouts) |
protected Timeouts timeouts
protected final ConnectionMetadata metadata
public static SubscribePersistentSubscriptionOptions get()
public int getBufferSize()
public SubscribePersistentSubscriptionOptions setBufferSize(int value)
public Timeouts getTimeouts()
public T timeouts(Timeouts timeouts)
public io.grpc.Metadata getMetadata()
public boolean hasUserCredentials()
public T authenticated(UserCredentials credentials)
public T requiresLeader()
public T notRequireLeader()
public T requiresLeader(boolean value)