static SubscriberSettings.Builder |
SubscriberSettings.newBuilder() |
|
abstract SubscriberSettings.Builder |
SubscriberSettings.Builder.setAssignmentServiceClient(PartitionAssignmentServiceClient client) |
A client to connect to the Pub/Sub lite assignment service.
|
abstract SubscriberSettings.Builder |
SubscriberSettings.Builder.setCredentialsProvider(com.google.api.gax.core.CredentialsProvider provider) |
A provider for credentials.
|
abstract SubscriberSettings.Builder |
SubscriberSettings.Builder.setCursorServiceClient(CursorServiceClient client) |
A CursorServiceClient to use, if present.
|
abstract SubscriberSettings.Builder |
SubscriberSettings.Builder.setFramework(PubsubContext.Framework framework) |
A Framework tag for internal metrics.
|
abstract SubscriberSettings.Builder |
SubscriberSettings.Builder.setNackHandler(NackHandler nackHandler) |
A handler for the action to take when AckReplyConsumer.nack() is called.
|
abstract SubscriberSettings.Builder |
SubscriberSettings.Builder.setPartitions(List<Partition> partition) |
The partitions this subscriber should connect to to receive messages.
|
abstract SubscriberSettings.Builder |
SubscriberSettings.Builder.setPerPartitionFlowControlSettings(FlowControlSettings settings) |
The per-partition flow control settings.
|
abstract SubscriberSettings.Builder |
SubscriberSettings.Builder.setReassignmentHandler(ReassignmentHandler reassignmentHandler) |
A handler that will be notified when partition assignments change from the backend.
|
abstract SubscriberSettings.Builder |
SubscriberSettings.Builder.setReceiver(com.google.cloud.pubsub.v1.MessageReceiver receiver) |
The receiver which handles new messages sent by the Pub/Sub Lite system.
|
abstract SubscriberSettings.Builder |
SubscriberSettings.Builder.setSubscriberServiceClient(SubscriberServiceClient client) |
A SubscriberServiceClient to use, if present.
|
abstract SubscriberSettings.Builder |
SubscriberSettings.Builder.setSubscriptionPath(SubscriptionPath path) |
The subscription to use to receive messages.
|
abstract SubscriberSettings.Builder |
SubscriberSettings.Builder.setTransformer(MessageTransformer<SequencedMessage,com.google.pubsub.v1.PubsubMessage> transformer) |
The MessageTransformer to get PubsubMessages from Pub/Sub Lite wire messages.
|