Skip to content

Commit 0a32739

Browse files
authored
---
yaml --- r: 27327 b: refs/heads/autosynth-talent c: 78360de h: refs/heads/master i: 27325: 7093cf3 27323: 4cf8f4f 27319: 0276fcd 27311: fe09da4 27295: 5a7a656 27263: 3cc7dc2
1 parent a8b5220 commit 0a32739

2 files changed

Lines changed: 13 additions & 13 deletions

File tree

  • branches/autosynth-talent/google-cloud-clients/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1

[refs]

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -170,7 +170,7 @@ refs/tags/v0.80.0: f745e744d38e4fe636f34d0e04795ba3d014287d
170170
refs/tags/v0.81.0: ed3a0c85339ea6b73560b9a570abfbb76b93a263
171171
refs/heads/autosynth-dataproc: 812eb0e76f4543bffe59701872476c4b5b7415f5
172172
refs/heads/autosynth-securitycenter: f2f2feb8f3949c986d37e55cd23cdb0ce774f287
173-
refs/heads/autosynth-talent: be7ece53c3f25fc81fa31fa0675e0a8f38d442d0
173+
refs/heads/autosynth-talent: 78360de040eb4d86d1b25a7792269d2952174d66
174174
refs/heads/cscc-samples: 620d105e6b574cfeeee04e413a157b7bd34ebc8b
175175
refs/heads/igorbernstein2-patch-1: f62464ee14df1e44a3b173cdc3976563d1b3078b
176176
refs/heads/mrschmidt-collectiongroup: a6d948bf3731a7e1ce1fcd3db8ab733a3c9b17de

branches/autosynth-talent/google-cloud-clients/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/Subscriber.java

Lines changed: 12 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -401,31 +401,31 @@ private void stopConnections(List<? extends ApiService> connections) {
401401
public static final class Builder {
402402
private static final Duration DEFAULT_MAX_ACK_EXTENSION_PERIOD = Duration.ofMinutes(60);
403403

404-
static final ExecutorProvider DEFAULT_EXECUTOR_PROVIDER =
404+
private static final ExecutorProvider DEFAULT_EXECUTOR_PROVIDER =
405405
InstantiatingExecutorProvider.newBuilder()
406406
.setExecutorThreadCount(THREADS_PER_CHANNEL)
407407
.build();
408408

409-
String subscriptionName;
410-
MessageReceiver receiver;
409+
private String subscriptionName;
410+
private MessageReceiver receiver;
411411

412-
Duration maxAckExtensionPeriod = DEFAULT_MAX_ACK_EXTENSION_PERIOD;
412+
private Duration maxAckExtensionPeriod = DEFAULT_MAX_ACK_EXTENSION_PERIOD;
413413

414-
FlowControlSettings flowControlSettings =
414+
private FlowControlSettings flowControlSettings =
415415
FlowControlSettings.newBuilder().setMaxOutstandingElementCount(1000L).build();
416416

417-
ExecutorProvider executorProvider = DEFAULT_EXECUTOR_PROVIDER;
418-
ExecutorProvider systemExecutorProvider = null;
419-
TransportChannelProvider channelProvider =
417+
private ExecutorProvider executorProvider = DEFAULT_EXECUTOR_PROVIDER;
418+
private ExecutorProvider systemExecutorProvider = null;
419+
private TransportChannelProvider channelProvider =
420420
SubscriptionAdminSettings.defaultGrpcTransportProviderBuilder()
421421
.setMaxInboundMessageSize(MAX_INBOUND_MESSAGE_SIZE)
422422
.setKeepAliveTime(Duration.ofMinutes(5))
423423
.build();
424-
HeaderProvider headerProvider = new NoHeaderProvider();
425-
CredentialsProvider credentialsProvider =
424+
private HeaderProvider headerProvider = new NoHeaderProvider();
425+
private CredentialsProvider credentialsProvider =
426426
SubscriptionAdminSettings.defaultCredentialsProviderBuilder().build();
427-
Optional<ApiClock> clock = Optional.absent();
428-
int parallelPullCount = 1;
427+
private Optional<ApiClock> clock = Optional.absent();
428+
private int parallelPullCount = 1;
429429

430430
Builder(String subscriptionName, MessageReceiver receiver) {
431431
this.subscriptionName = subscriptionName;

0 commit comments

Comments
 (0)