static Subscriber.Builder |
Subscriber.newBuilder(ProjectSubscriptionName subscription,
MessageReceiver receiver) |
|
static Subscriber.Builder |
Subscriber.newBuilder(ProjectSubscriptionName subscription,
MessageReceiverWithAckResponse receiver) |
|
static Subscriber.Builder |
Subscriber.newBuilder(String subscription,
MessageReceiver receiver) |
|
static Subscriber.Builder |
Subscriber.newBuilder(String subscription,
MessageReceiverWithAckResponse receiver) |
|
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.setMaxDurationPerAckExtension(org.threeten.bp.Duration maxDurationPerAckExtension) |
Set the upper bound for a single mod ack extention period.
|
Subscriber.Builder |
Subscriber.Builder.setMinDurationPerAckExtension(org.threeten.bp.Duration minDurationPerAckExtension) |
Set the lower bound for a single mod ack extention period.
|
Subscriber.Builder |
Subscriber.Builder.setParallelPullCount(int parallelPullCount) |
Sets the number of StreamingPull streams 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.
|
Subscriber.Builder |
Subscriber.Builder.setUseLegacyFlowControl(boolean value) |
Disables enforcing flow control settings at the Cloud PubSub server and uses the less
accurate method of only enforcing flow control at the client side.
|