diff --git a/google-cloud-clients/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/Subscriber.java b/google-cloud-clients/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/Subscriber.java index eb42ad82b7b6..5433eb753bca 100644 --- a/google-cloud-clients/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/Subscriber.java +++ b/google-cloud-clients/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/Subscriber.java @@ -401,31 +401,31 @@ private void stopConnections(List connections) { public static final class Builder { private static final Duration DEFAULT_MAX_ACK_EXTENSION_PERIOD = Duration.ofMinutes(60); - static final ExecutorProvider DEFAULT_EXECUTOR_PROVIDER = + private static final ExecutorProvider DEFAULT_EXECUTOR_PROVIDER = InstantiatingExecutorProvider.newBuilder() .setExecutorThreadCount(THREADS_PER_CHANNEL) .build(); - String subscriptionName; - MessageReceiver receiver; + private String subscriptionName; + private MessageReceiver receiver; - Duration maxAckExtensionPeriod = DEFAULT_MAX_ACK_EXTENSION_PERIOD; + private Duration maxAckExtensionPeriod = DEFAULT_MAX_ACK_EXTENSION_PERIOD; - FlowControlSettings flowControlSettings = + private FlowControlSettings flowControlSettings = FlowControlSettings.newBuilder().setMaxOutstandingElementCount(1000L).build(); - ExecutorProvider executorProvider = DEFAULT_EXECUTOR_PROVIDER; - ExecutorProvider systemExecutorProvider = null; - TransportChannelProvider channelProvider = + private ExecutorProvider executorProvider = DEFAULT_EXECUTOR_PROVIDER; + private ExecutorProvider systemExecutorProvider = null; + private TransportChannelProvider channelProvider = SubscriptionAdminSettings.defaultGrpcTransportProviderBuilder() .setMaxInboundMessageSize(MAX_INBOUND_MESSAGE_SIZE) .setKeepAliveTime(Duration.ofMinutes(5)) .build(); - HeaderProvider headerProvider = new NoHeaderProvider(); - CredentialsProvider credentialsProvider = + private HeaderProvider headerProvider = new NoHeaderProvider(); + private CredentialsProvider credentialsProvider = SubscriptionAdminSettings.defaultCredentialsProviderBuilder().build(); - Optional clock = Optional.absent(); - int parallelPullCount = 1; + private Optional clock = Optional.absent(); + private int parallelPullCount = 1; Builder(String subscriptionName, MessageReceiver receiver) { this.subscriptionName = subscriptionName;