Package | Description |
---|---|
com.google.cloud.pubsub.v1 |
A client to Google Cloud Pub/Sub API.
|
Modifier and Type | Method and Description |
---|---|
static Subscriber.Builder |
Subscriber.newBuilder(ProjectSubscriptionName subscription,
MessageReceiver receiver)
Constructs a new
Subscriber.Builder . |
static Subscriber.Builder |
Subscriber.newBuilder(String subscription,
MessageReceiver receiver)
Constructs a new
Subscriber.Builder . |
Subscriber.Builder |
Subscriber.Builder.setChannelProvider(com.google.api.gax.rpc.TransportChannelProvider channelProvider)
ChannelProvider to use to create Channels, which must point at Cloud Pub/Sub
endpoint. |
Subscriber.Builder |
Subscriber.Builder.setCredentialsProvider(com.google.api.gax.core.CredentialsProvider credentialsProvider)
CredentialsProvider to use to create Credentials to authenticate calls. |
Subscriber.Builder |
Subscriber.Builder.setEndpoint(String endpoint)
Gives the ability to override the gRPC endpoint.
|
Subscriber.Builder |
Subscriber.Builder.setExecutorProvider(com.google.api.gax.core.ExecutorProvider executorProvider)
Gives the ability to set a custom executor.
|
Subscriber.Builder |
Subscriber.Builder.setFlowControlSettings(com.google.api.gax.batching.FlowControlSettings flowControlSettings)
Sets the flow control settings.
|
Subscriber.Builder |
Subscriber.Builder.setHeaderProvider(com.google.api.gax.rpc.HeaderProvider headerProvider)
Sets the static header provider.
|
Subscriber.Builder |
Subscriber.Builder.setMaxAckExtensionPeriod(org.threeten.bp.Duration maxAckExtensionPeriod)
Set the maximum period a message ack deadline will be extended.
|
Subscriber.Builder |
Subscriber.Builder.setParallelPullCount(int parallelPullCount)
Sets the number of pullers used to pull messages from the subscription.
|
Subscriber.Builder |
Subscriber.Builder.setSystemExecutorProvider(com.google.api.gax.core.ExecutorProvider executorProvider)
Gives the ability to set a custom executor for managing lease extensions.
|
Copyright © 2019 Google LLC. All rights reserved.