Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
/*
* Copyright 2019 Google LLC
* Copyright 2020 Google LLC
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
Expand Down Expand Up @@ -251,7 +251,6 @@ public final Subscription createSubscription(
ProjectTopicName topic,
PushConfig pushConfig,
int ackDeadlineSeconds) {

Subscription request =
Subscription.newBuilder()
.setName(name == null ? null : name.toString())
Expand Down Expand Up @@ -317,7 +316,6 @@ public final Subscription createSubscription(
*/
public final Subscription createSubscription(
String name, String topic, PushConfig pushConfig, int ackDeadlineSeconds) {

Subscription request =
Subscription.newBuilder()
.setName(name)
Expand Down Expand Up @@ -413,7 +411,6 @@ public final UnaryCallable<Subscription, Subscription> createSubscriptionCallabl
* @throws com.google.api.gax.rpc.ApiException if the remote call fails
*/
public final Subscription getSubscription(ProjectSubscriptionName subscription) {

GetSubscriptionRequest request =
GetSubscriptionRequest.newBuilder()
.setSubscription(subscription == null ? null : subscription.toString())
Expand All @@ -439,7 +436,6 @@ public final Subscription getSubscription(ProjectSubscriptionName subscription)
* @throws com.google.api.gax.rpc.ApiException if the remote call fails
*/
public final Subscription getSubscription(String subscription) {

GetSubscriptionRequest request =
GetSubscriptionRequest.newBuilder().setSubscription(subscription).build();
return getSubscription(request);
Expand Down Expand Up @@ -710,7 +706,6 @@ public final ListSubscriptionsPagedResponse listSubscriptions(ListSubscriptionsR
* @throws com.google.api.gax.rpc.ApiException if the remote call fails
*/
public final void deleteSubscription(ProjectSubscriptionName subscription) {

DeleteSubscriptionRequest request =
DeleteSubscriptionRequest.newBuilder()
.setSubscription(subscription == null ? null : subscription.toString())
Expand Down Expand Up @@ -739,7 +734,6 @@ public final void deleteSubscription(ProjectSubscriptionName subscription) {
* @throws com.google.api.gax.rpc.ApiException if the remote call fails
*/
public final void deleteSubscription(String subscription) {

DeleteSubscriptionRequest request =
DeleteSubscriptionRequest.newBuilder().setSubscription(subscription).build();
deleteSubscription(request);
Expand Down Expand Up @@ -828,7 +822,6 @@ public final UnaryCallable<DeleteSubscriptionRequest, Empty> deleteSubscriptionC
*/
/* package-private */ final void modifyAckDeadline(
ProjectSubscriptionName subscription, List<String> ackIds, int ackDeadlineSeconds) {

ModifyAckDeadlineRequest request =
ModifyAckDeadlineRequest.newBuilder()
.setSubscription(subscription == null ? null : subscription.toString())
Expand Down Expand Up @@ -870,7 +863,6 @@ public final UnaryCallable<DeleteSubscriptionRequest, Empty> deleteSubscriptionC
*/
/* package-private */ final void modifyAckDeadline(
String subscription, List<String> ackIds, int ackDeadlineSeconds) {

ModifyAckDeadlineRequest request =
ModifyAckDeadlineRequest.newBuilder()
.setSubscription(subscription)
Expand Down Expand Up @@ -966,7 +958,6 @@ public final UnaryCallable<DeleteSubscriptionRequest, Empty> deleteSubscriptionC
*/
/* package-private */ final void acknowledge(
ProjectSubscriptionName subscription, List<String> ackIds) {

AcknowledgeRequest request =
AcknowledgeRequest.newBuilder()
.setSubscription(subscription == null ? null : subscription.toString())
Expand Down Expand Up @@ -1000,7 +991,6 @@ public final UnaryCallable<DeleteSubscriptionRequest, Empty> deleteSubscriptionC
* @throws com.google.api.gax.rpc.ApiException if the remote call fails
*/
/* package-private */ final void acknowledge(String subscription, List<String> ackIds) {

AcknowledgeRequest request =
AcknowledgeRequest.newBuilder().setSubscription(subscription).addAllAckIds(ackIds).build();
acknowledge(request);
Expand Down Expand Up @@ -1091,7 +1081,6 @@ public final UnaryCallable<DeleteSubscriptionRequest, Empty> deleteSubscriptionC
*/
/* package-private */ final PullResponse pull(
ProjectSubscriptionName subscription, boolean returnImmediately, int maxMessages) {

PullRequest request =
PullRequest.newBuilder()
.setSubscription(subscription == null ? null : subscription.toString())
Expand Down Expand Up @@ -1129,7 +1118,6 @@ public final UnaryCallable<DeleteSubscriptionRequest, Empty> deleteSubscriptionC
*/
/* package-private */ final PullResponse pull(
String subscription, boolean returnImmediately, int maxMessages) {

PullRequest request =
PullRequest.newBuilder()
.setSubscription(subscription)
Expand Down Expand Up @@ -1252,7 +1240,6 @@ public final UnaryCallable<DeleteSubscriptionRequest, Empty> deleteSubscriptionC
* @throws com.google.api.gax.rpc.ApiException if the remote call fails
*/
public final void modifyPushConfig(ProjectSubscriptionName subscription, PushConfig pushConfig) {

ModifyPushConfigRequest request =
ModifyPushConfigRequest.newBuilder()
.setSubscription(subscription == null ? null : subscription.toString())
Expand Down Expand Up @@ -1289,7 +1276,6 @@ public final void modifyPushConfig(ProjectSubscriptionName subscription, PushCon
* @throws com.google.api.gax.rpc.ApiException if the remote call fails
*/
public final void modifyPushConfig(String subscription, PushConfig pushConfig) {

ModifyPushConfigRequest request =
ModifyPushConfigRequest.newBuilder()
.setSubscription(subscription)
Expand Down Expand Up @@ -1545,7 +1531,6 @@ public final UnaryCallable<ListSnapshotsRequest, ListSnapshotsResponse> listSnap
*/
public final Snapshot createSnapshot(
ProjectSnapshotName name, ProjectSubscriptionName subscription) {

CreateSnapshotRequest request =
CreateSnapshotRequest.newBuilder()
.setName(name == null ? null : name.toString())
Expand Down Expand Up @@ -1594,7 +1579,6 @@ public final Snapshot createSnapshot(
* @throws com.google.api.gax.rpc.ApiException if the remote call fails
*/
public final Snapshot createSnapshot(String name, String subscription) {

CreateSnapshotRequest request =
CreateSnapshotRequest.newBuilder().setName(name).setSubscription(subscription).build();
return createSnapshot(request);
Expand Down Expand Up @@ -1773,7 +1757,6 @@ public final UnaryCallable<UpdateSnapshotRequest, Snapshot> updateSnapshotCallab
* @throws com.google.api.gax.rpc.ApiException if the remote call fails
*/
public final void deleteSnapshot(ProjectSnapshotName snapshot) {

DeleteSnapshotRequest request =
DeleteSnapshotRequest.newBuilder()
.setSnapshot(snapshot == null ? null : snapshot.toString())
Expand Down Expand Up @@ -1806,7 +1789,6 @@ public final void deleteSnapshot(ProjectSnapshotName snapshot) {
* @throws com.google.api.gax.rpc.ApiException if the remote call fails
*/
public final void deleteSnapshot(String snapshot) {

DeleteSnapshotRequest request =
DeleteSnapshotRequest.newBuilder().setSnapshot(snapshot).build();
deleteSnapshot(request);
Expand Down Expand Up @@ -1948,7 +1930,6 @@ public final UnaryCallable<SeekRequest, SeekResponse> seekCallable() {
* @throws com.google.api.gax.rpc.ApiException if the remote call fails
*/
public final Policy setIamPolicy(String resource, Policy policy) {

SetIamPolicyRequest request =
SetIamPolicyRequest.newBuilder().setResource(resource).setPolicy(policy).build();
return setIamPolicy(request);
Expand Down Expand Up @@ -2022,7 +2003,6 @@ public final UnaryCallable<SetIamPolicyRequest, Policy> setIamPolicyCallable() {
* @throws com.google.api.gax.rpc.ApiException if the remote call fails
*/
public final Policy getIamPolicy(String resource) {

GetIamPolicyRequest request = GetIamPolicyRequest.newBuilder().setResource(resource).build();
return getIamPolicy(request);
}
Expand Down Expand Up @@ -2102,7 +2082,6 @@ public final UnaryCallable<GetIamPolicyRequest, Policy> getIamPolicyCallable() {
*/
public final TestIamPermissionsResponse testIamPermissions(
String resource, List<String> permissions) {

TestIamPermissionsRequest request =
TestIamPermissionsRequest.newBuilder()
.setResource(resource)
Expand Down
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
/*
* Copyright 2019 Google LLC
* Copyright 2020 Google LLC
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
Expand Down
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
/*
* Copyright 2019 Google LLC
* Copyright 2020 Google LLC
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
Expand Down Expand Up @@ -198,7 +198,6 @@ public PublisherStub getStub() {
* @throws com.google.api.gax.rpc.ApiException if the remote call fails
*/
public final Topic createTopic(ProjectTopicName name) {

Topic request = Topic.newBuilder().setName(name == null ? null : name.toString()).build();
return createTopic(request);
}
Expand Down Expand Up @@ -226,7 +225,6 @@ public final Topic createTopic(ProjectTopicName name) {
* @throws com.google.api.gax.rpc.ApiException if the remote call fails
*/
public final Topic createTopic(String name) {

Topic request = Topic.newBuilder().setName(name).build();
return createTopic(request);
}
Expand Down Expand Up @@ -354,7 +352,6 @@ public final UnaryCallable<UpdateTopicRequest, Topic> updateTopicCallable() {
*/
/* package-private */ final PublishResponse publish(
ProjectTopicName topic, List<PubsubMessage> messages) {

PublishRequest request =
PublishRequest.newBuilder()
.setTopic(topic == null ? null : topic.toString())
Expand Down Expand Up @@ -387,7 +384,6 @@ public final UnaryCallable<UpdateTopicRequest, Topic> updateTopicCallable() {
* @throws com.google.api.gax.rpc.ApiException if the remote call fails
*/
/* package-private */ final PublishResponse publish(String topic, List<PubsubMessage> messages) {

PublishRequest request =
PublishRequest.newBuilder().setTopic(topic).addAllMessages(messages).build();
return publish(request);
Expand Down Expand Up @@ -467,7 +463,6 @@ public final UnaryCallable<UpdateTopicRequest, Topic> updateTopicCallable() {
* @throws com.google.api.gax.rpc.ApiException if the remote call fails
*/
public final Topic getTopic(ProjectTopicName topic) {

GetTopicRequest request =
GetTopicRequest.newBuilder().setTopic(topic == null ? null : topic.toString()).build();
return getTopic(request);
Expand All @@ -490,7 +485,6 @@ public final Topic getTopic(ProjectTopicName topic) {
* @throws com.google.api.gax.rpc.ApiException if the remote call fails
*/
public final Topic getTopic(String topic) {

GetTopicRequest request = GetTopicRequest.newBuilder().setTopic(topic).build();
return getTopic(request);
}
Expand Down Expand Up @@ -826,7 +820,6 @@ public final ListTopicSubscriptionsPagedResponse listTopicSubscriptions(
* @throws com.google.api.gax.rpc.ApiException if the remote call fails
*/
public final void deleteTopic(ProjectTopicName topic) {

DeleteTopicRequest request =
DeleteTopicRequest.newBuilder().setTopic(topic == null ? null : topic.toString()).build();
deleteTopic(request);
Expand All @@ -852,7 +845,6 @@ public final void deleteTopic(ProjectTopicName topic) {
* @throws com.google.api.gax.rpc.ApiException if the remote call fails
*/
public final void deleteTopic(String topic) {

DeleteTopicRequest request = DeleteTopicRequest.newBuilder().setTopic(topic).build();
deleteTopic(request);
}
Expand Down Expand Up @@ -930,7 +922,6 @@ public final UnaryCallable<DeleteTopicRequest, Empty> deleteTopicCallable() {
* @throws com.google.api.gax.rpc.ApiException if the remote call fails
*/
public final Policy setIamPolicy(String resource, Policy policy) {

SetIamPolicyRequest request =
SetIamPolicyRequest.newBuilder().setResource(resource).setPolicy(policy).build();
return setIamPolicy(request);
Expand Down Expand Up @@ -1004,7 +995,6 @@ public final UnaryCallable<SetIamPolicyRequest, Policy> setIamPolicyCallable() {
* @throws com.google.api.gax.rpc.ApiException if the remote call fails
*/
public final Policy getIamPolicy(String resource) {

GetIamPolicyRequest request = GetIamPolicyRequest.newBuilder().setResource(resource).build();
return getIamPolicy(request);
}
Expand Down Expand Up @@ -1084,7 +1074,6 @@ public final UnaryCallable<GetIamPolicyRequest, Policy> getIamPolicyCallable() {
*/
public final TestIamPermissionsResponse testIamPermissions(
String resource, List<String> permissions) {

TestIamPermissionsRequest request =
TestIamPermissionsRequest.newBuilder()
.setResource(resource)
Expand Down
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
/*
* Copyright 2019 Google LLC
* Copyright 2020 Google LLC
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
Expand Down
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
/*
* Copyright 2019 Google LLC
* Copyright 2020 Google LLC
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
Expand Down
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
/*
* Copyright 2019 Google LLC
* Copyright 2020 Google LLC
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
Expand Down
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
/*
* Copyright 2019 Google LLC
* Copyright 2020 Google LLC
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
Expand Down
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
/*
* Copyright 2019 Google LLC
* Copyright 2020 Google LLC
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
Expand Down
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
/*
* Copyright 2019 Google LLC
* Copyright 2020 Google LLC
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
Expand Down
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
/*
* Copyright 2019 Google LLC
* Copyright 2020 Google LLC
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
Expand Down
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
/*
* Copyright 2019 Google LLC
* Copyright 2020 Google LLC
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
Expand Down
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
/*
* Copyright 2019 Google LLC
* Copyright 2020 Google LLC
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
Expand Down
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
/*
* Copyright 2019 Google LLC
* Copyright 2020 Google LLC
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
Expand Down
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
/*
* Copyright 2019 Google LLC
* Copyright 2020 Google LLC
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
Expand Down
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
/*
* Copyright 2019 Google LLC
* Copyright 2020 Google LLC
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
Expand Down
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
/*
* Copyright 2019 Google LLC
* Copyright 2020 Google LLC
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
Expand Down
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
/*
* Copyright 2019 Google LLC
* Copyright 2020 Google LLC
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
Expand Down
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
/*
* Copyright 2019 Google LLC
* Copyright 2020 Google LLC
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
Expand Down
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
/*
* Copyright 2019 Google LLC
* Copyright 2020 Google LLC
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
Expand Down
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
/*
* Copyright 2019 Google LLC
* Copyright 2020 Google LLC
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
Expand Down
Loading