diff --git a/grpc-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/SchemaServiceGrpc.java b/grpc-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/SchemaServiceGrpc.java deleted file mode 100644 index ce5099a57..000000000 --- a/grpc-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/SchemaServiceGrpc.java +++ /dev/null @@ -1,905 +0,0 @@ -/* - * 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. - * You may obtain a copy of the License at - * - * https://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package com.google.pubsub.v1; - -import static io.grpc.MethodDescriptor.generateFullMethodName; - -/** - * - * - *
- * Service for doing schema-related operations. - *- */ -@javax.annotation.Generated( - value = "by gRPC proto compiler", - comments = "Source: google/pubsub/v1/schema.proto") -public final class SchemaServiceGrpc { - - private SchemaServiceGrpc() {} - - public static final String SERVICE_NAME = "google.pubsub.v1.SchemaService"; - - // Static method descriptors that strictly reflect the proto. - private static volatile io.grpc.MethodDescriptor< - com.google.pubsub.v1.CreateSchemaRequest, com.google.pubsub.v1.Schema> - getCreateSchemaMethod; - - @io.grpc.stub.annotations.RpcMethod( - fullMethodName = SERVICE_NAME + '/' + "CreateSchema", - requestType = com.google.pubsub.v1.CreateSchemaRequest.class, - responseType = com.google.pubsub.v1.Schema.class, - methodType = io.grpc.MethodDescriptor.MethodType.UNARY) - public static io.grpc.MethodDescriptor< - com.google.pubsub.v1.CreateSchemaRequest, com.google.pubsub.v1.Schema> - getCreateSchemaMethod() { - io.grpc.MethodDescriptor
- * Service for doing schema-related operations. - *- */ - public abstract static class SchemaServiceImplBase implements io.grpc.BindableService { - - /** - * - * - *
- * Creates a schema. - *- */ - public void createSchema( - com.google.pubsub.v1.CreateSchemaRequest request, - io.grpc.stub.StreamObserver
- * Gets a schema. - *- */ - public void getSchema( - com.google.pubsub.v1.GetSchemaRequest request, - io.grpc.stub.StreamObserver
- * Lists schemas in a project. - *- */ - public void listSchemas( - com.google.pubsub.v1.ListSchemasRequest request, - io.grpc.stub.StreamObserver
- * Deletes a schema. - *- */ - public void deleteSchema( - com.google.pubsub.v1.DeleteSchemaRequest request, - io.grpc.stub.StreamObserver
- * Validates a schema. - *- */ - public void validateSchema( - com.google.pubsub.v1.ValidateSchemaRequest request, - io.grpc.stub.StreamObserver
- * Validates a message against a schema. - *- */ - public void validateMessage( - com.google.pubsub.v1.ValidateMessageRequest request, - io.grpc.stub.StreamObserver
- * Service for doing schema-related operations. - *- */ - public static final class SchemaServiceStub - extends io.grpc.stub.AbstractAsyncStub
- * Creates a schema. - *- */ - public void createSchema( - com.google.pubsub.v1.CreateSchemaRequest request, - io.grpc.stub.StreamObserver
- * Gets a schema. - *- */ - public void getSchema( - com.google.pubsub.v1.GetSchemaRequest request, - io.grpc.stub.StreamObserver
- * Lists schemas in a project. - *- */ - public void listSchemas( - com.google.pubsub.v1.ListSchemasRequest request, - io.grpc.stub.StreamObserver
- * Deletes a schema. - *- */ - public void deleteSchema( - com.google.pubsub.v1.DeleteSchemaRequest request, - io.grpc.stub.StreamObserver
- * Validates a schema. - *- */ - public void validateSchema( - com.google.pubsub.v1.ValidateSchemaRequest request, - io.grpc.stub.StreamObserver
- * Validates a message against a schema. - *- */ - public void validateMessage( - com.google.pubsub.v1.ValidateMessageRequest request, - io.grpc.stub.StreamObserver
- * Service for doing schema-related operations. - *- */ - public static final class SchemaServiceBlockingStub - extends io.grpc.stub.AbstractBlockingStub
- * Creates a schema. - *- */ - public com.google.pubsub.v1.Schema createSchema( - com.google.pubsub.v1.CreateSchemaRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( - getChannel(), getCreateSchemaMethod(), getCallOptions(), request); - } - - /** - * - * - *
- * Gets a schema. - *- */ - public com.google.pubsub.v1.Schema getSchema(com.google.pubsub.v1.GetSchemaRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( - getChannel(), getGetSchemaMethod(), getCallOptions(), request); - } - - /** - * - * - *
- * Lists schemas in a project. - *- */ - public com.google.pubsub.v1.ListSchemasResponse listSchemas( - com.google.pubsub.v1.ListSchemasRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( - getChannel(), getListSchemasMethod(), getCallOptions(), request); - } - - /** - * - * - *
- * Deletes a schema. - *- */ - public com.google.protobuf.Empty deleteSchema( - com.google.pubsub.v1.DeleteSchemaRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( - getChannel(), getDeleteSchemaMethod(), getCallOptions(), request); - } - - /** - * - * - *
- * Validates a schema. - *- */ - public com.google.pubsub.v1.ValidateSchemaResponse validateSchema( - com.google.pubsub.v1.ValidateSchemaRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( - getChannel(), getValidateSchemaMethod(), getCallOptions(), request); - } - - /** - * - * - *
- * Validates a message against a schema. - *- */ - public com.google.pubsub.v1.ValidateMessageResponse validateMessage( - com.google.pubsub.v1.ValidateMessageRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( - getChannel(), getValidateMessageMethod(), getCallOptions(), request); - } - } - - /** - * - * - *
- * Service for doing schema-related operations. - *- */ - public static final class SchemaServiceFutureStub - extends io.grpc.stub.AbstractFutureStub
- * Creates a schema. - *- */ - public com.google.common.util.concurrent.ListenableFuture
- * Gets a schema. - *- */ - public com.google.common.util.concurrent.ListenableFuture
- * Lists schemas in a project. - *- */ - public com.google.common.util.concurrent.ListenableFuture< - com.google.pubsub.v1.ListSchemasResponse> - listSchemas(com.google.pubsub.v1.ListSchemasRequest request) { - return io.grpc.stub.ClientCalls.futureUnaryCall( - getChannel().newCall(getListSchemasMethod(), getCallOptions()), request); - } - - /** - * - * - *
- * Deletes a schema. - *- */ - public com.google.common.util.concurrent.ListenableFuture
- * Validates a schema. - *- */ - public com.google.common.util.concurrent.ListenableFuture< - com.google.pubsub.v1.ValidateSchemaResponse> - validateSchema(com.google.pubsub.v1.ValidateSchemaRequest request) { - return io.grpc.stub.ClientCalls.futureUnaryCall( - getChannel().newCall(getValidateSchemaMethod(), getCallOptions()), request); - } - - /** - * - * - *
- * Validates a message against a schema. - *- */ - public com.google.common.util.concurrent.ListenableFuture< - com.google.pubsub.v1.ValidateMessageResponse> - validateMessage(com.google.pubsub.v1.ValidateMessageRequest request) { - return io.grpc.stub.ClientCalls.futureUnaryCall( - getChannel().newCall(getValidateMessageMethod(), getCallOptions()), request); - } - } - - private static final int METHODID_CREATE_SCHEMA = 0; - private static final int METHODID_GET_SCHEMA = 1; - private static final int METHODID_LIST_SCHEMAS = 2; - private static final int METHODID_DELETE_SCHEMA = 3; - private static final int METHODID_VALIDATE_SCHEMA = 4; - private static final int METHODID_VALIDATE_MESSAGE = 5; - - private static final class MethodHandlers
{@code * try (SchemaServiceClient schemaServiceClient = SchemaServiceClient.create()) { - * String parent = ProjectName.of("[PROJECT]").toString(); + * String parent = SchemaName.of("[PROJECT]", "[SCHEMA]").toString(); * Schema schema = Schema.newBuilder().build(); * String schemaId = "schemaId-697673060"; * Schema response = schemaServiceClient.createSchema(parent, schema, schemaId); @@ -248,7 +248,7 @@ public final Schema createSchema(String parent, Schema schema, String schemaId) * try (SchemaServiceClient schemaServiceClient = SchemaServiceClient.create()) { * CreateSchemaRequest request = * CreateSchemaRequest.newBuilder() - * .setParent(ProjectName.of("[PROJECT]").toString()) + * .setParent(SchemaName.of("[PROJECT]", "[SCHEMA]").toString()) * .setSchema(Schema.newBuilder().build()) * .setSchemaId("schemaId-697673060") * .build(); @@ -273,7 +273,7 @@ public final Schema createSchema(CreateSchemaRequest request) { * try (SchemaServiceClient schemaServiceClient = SchemaServiceClient.create()) { * CreateSchemaRequest request = * CreateSchemaRequest.newBuilder() - * .setParent(ProjectName.of("[PROJECT]").toString()) + * .setParent(SchemaName.of("[PROJECT]", "[SCHEMA]").toString()) * .setSchema(Schema.newBuilder().build()) * .setSchemaId("schemaId-697673060") * .build(); @@ -473,7 +473,7 @@ public final ListSchemasPagedResponse listSchemas(ListSchemasRequest request) { * .setPageSize(883849137) * .setPageToken("pageToken873572522") * .build(); - * ApiFuturefuture = schemaServiceClient.listSchemasPagedCallable().futureCall(request); + * ApiFuture future = schemaServiceClient.listSchemasPagedCallable().futureCall(request); * // Do something. * for (Schema element : future.get().iterateAll()) { * // doThingsWith(element); @@ -503,7 +503,7 @@ public final ListSchemasPagedResponse listSchemas(ListSchemasRequest request) { * .build(); * while (true) { * ListSchemasResponse response = schemaServiceClient.listSchemasCallable().call(request); - * for (Schema element : response.getSchemasList()) { + * for (Schema element : response.getResponsesList()) { * // doThingsWith(element); * } * String nextPageToken = response.getNextPageToken(); @@ -954,10 +954,7 @@ public boolean awaitTermination(long duration, TimeUnit unit) throws Interrupted public static class ListSchemasPagedResponse extends AbstractPagedListResponse< - ListSchemasRequest, - ListSchemasResponse, - Schema, - ListSchemasPage, + ListSchemasRequest, ListSchemasResponse, Schema, ListSchemasPage, ListSchemasFixedSizeCollection> { public static ApiFuture createAsync( @@ -1004,10 +1001,7 @@ public ApiFuture createPageAsync( public static class ListSchemasFixedSizeCollection extends AbstractFixedSizeCollection< - ListSchemasRequest, - ListSchemasResponse, - Schema, - ListSchemasPage, + ListSchemasRequest, ListSchemasResponse, Schema, ListSchemasPage, ListSchemasFixedSizeCollection> { private ListSchemasFixedSizeCollection(List pages, int collectionSize) { diff --git a/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/SchemaServiceSettings.java b/owl-bot-staging/v1/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/SchemaServiceSettings.java similarity index 97% rename from google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/SchemaServiceSettings.java rename to owl-bot-staging/v1/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/SchemaServiceSettings.java index e8c50371c..7d20e8c94 100644 --- a/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/SchemaServiceSettings.java +++ b/owl-bot-staging/v1/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/SchemaServiceSettings.java @@ -27,6 +27,7 @@ import com.google.api.gax.rpc.ClientContext; import com.google.api.gax.rpc.ClientSettings; import com.google.api.gax.rpc.PagedCallSettings; +import com.google.api.gax.rpc.StubSettings; import com.google.api.gax.rpc.TransportChannelProvider; import com.google.api.gax.rpc.UnaryCallSettings; import com.google.cloud.pubsub.v1.stub.SchemaServiceStubSettings; @@ -57,9 +58,9 @@ * The default instance has everything set to sensible defaults: * *
- *
* *- The default service address (pubsub.googleapis.com) and default port (443) are used. - *
- Credentials are acquired automatically through Application Default Credentials. - *
- Retries are configured for idempotent methods but not for non-idempotent methods. + *
- The default service address (pubsub.googleapis.com) and default port (443) are used. + *
- Credentials are acquired automatically through Application Default Credentials. + *
- Retries are configured for idempotent methods but not for non-idempotent methods. *
The builder of this class is recursive, so contained classes are themselves builders. When diff --git a/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/SubscriptionAdminClient.java b/owl-bot-staging/v1/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/SubscriptionAdminClient.java similarity index 87% rename from google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/SubscriptionAdminClient.java rename to owl-bot-staging/v1/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/SubscriptionAdminClient.java index 6d1c6950a..2ab5a2ddd 100644 --- a/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/SubscriptionAdminClient.java +++ b/owl-bot-staging/v1/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/SubscriptionAdminClient.java @@ -48,18 +48,17 @@ import com.google.pubsub.v1.ModifyAckDeadlineRequest; import com.google.pubsub.v1.ModifyPushConfigRequest; import com.google.pubsub.v1.ProjectName; -import com.google.pubsub.v1.ProjectSnapshotName; -import com.google.pubsub.v1.ProjectSubscriptionName; -import com.google.pubsub.v1.ProjectTopicName; import com.google.pubsub.v1.PullRequest; import com.google.pubsub.v1.PullResponse; import com.google.pubsub.v1.PushConfig; import com.google.pubsub.v1.SeekRequest; import com.google.pubsub.v1.SeekResponse; import com.google.pubsub.v1.Snapshot; +import com.google.pubsub.v1.SnapshotName; import com.google.pubsub.v1.StreamingPullRequest; import com.google.pubsub.v1.StreamingPullResponse; import com.google.pubsub.v1.Subscription; +import com.google.pubsub.v1.SubscriptionName; import com.google.pubsub.v1.TopicName; import com.google.pubsub.v1.UpdateSnapshotRequest; import com.google.pubsub.v1.UpdateSubscriptionRequest; @@ -79,7 +78,7 @@ * *
{@code * try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) { - * ProjectSubscriptionName name = ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]"); + * SubscriptionName name = SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]"); * TopicName topic = TopicName.ofProjectTopicName("[PROJECT]", "[TOPIC]"); * PushConfig pushConfig = PushConfig.newBuilder().build(); * int ackDeadlineSeconds = 2135351438; @@ -96,13 +95,13 @@ * methods: * *- *
* @@ -207,7 +206,7 @@ public SubscriberStub getStub() { * *- A "flattened" method. With this type of method, the fields of the request type have been + *
- A "flattened" method. With this type of method, the fields of the request type have been * converted into function parameters. It may be the case that not all fields are available as * parameters, and not every API method will have a flattened method entry point. - *
- A "request object" method. This type of method only takes one parameter, a request object, + *
- A "request object" method. This type of method only takes one parameter, a request object, * which must be constructed before the call. Not every API method will have a request object * method. - *
- A "callable" method. This type of method takes no parameters and returns an immutable API + *
- A "callable" method. This type of method takes no parameters and returns an immutable API * callable object, which can be used to initiate calls to the service. *
{@code * try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) { - * ProjectSubscriptionName name = ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]"); + * SubscriptionName name = SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]"); * TopicName topic = TopicName.ofProjectTopicName("[PROJECT]", "[TOPIC]"); * PushConfig pushConfig = PushConfig.newBuilder().build(); * int ackDeadlineSeconds = 2135351438; @@ -245,10 +244,7 @@ public SubscriberStub getStub() { * @throws com.google.api.gax.rpc.ApiException if the remote call fails */ public final Subscription createSubscription( - ProjectSubscriptionName name, - TopicName topic, - PushConfig pushConfig, - int ackDeadlineSeconds) { + SubscriptionName name, TopicName topic, PushConfig pushConfig, int ackDeadlineSeconds) { Subscription request = Subscription.newBuilder() .setName(name == null ? null : name.toString()) @@ -276,7 +272,7 @@ public final Subscription createSubscription( * *{@code * try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) { - * ProjectSubscriptionName name = ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]"); + * SubscriptionName name = SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]"); * String topic = TopicName.ofProjectTopicName("[PROJECT]", "[TOPIC]").toString(); * PushConfig pushConfig = PushConfig.newBuilder().build(); * int ackDeadlineSeconds = 2135351438; @@ -314,7 +310,7 @@ public final Subscription createSubscription( * @throws com.google.api.gax.rpc.ApiException if the remote call fails */ public final Subscription createSubscription( - ProjectSubscriptionName name, String topic, PushConfig pushConfig, int ackDeadlineSeconds) { + SubscriptionName name, String topic, PushConfig pushConfig, int ackDeadlineSeconds) { Subscription request = Subscription.newBuilder() .setName(name == null ? null : name.toString()) @@ -342,7 +338,7 @@ public final Subscription createSubscription( * *{@code * try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) { - * String name = ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString(); + * String name = SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString(); * TopicName topic = TopicName.ofProjectTopicName("[PROJECT]", "[TOPIC]"); * PushConfig pushConfig = PushConfig.newBuilder().build(); * int ackDeadlineSeconds = 2135351438; @@ -408,7 +404,7 @@ public final Subscription createSubscription( * *{@code * try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) { - * String name = ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString(); + * String name = SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString(); * String topic = TopicName.ofProjectTopicName("[PROJECT]", "[TOPIC]").toString(); * PushConfig pushConfig = PushConfig.newBuilder().build(); * int ackDeadlineSeconds = 2135351438; @@ -476,7 +472,7 @@ public final Subscription createSubscription( * try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) { * Subscription request = * Subscription.newBuilder() - * .setName(ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString()) + * .setName(SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString()) * .setTopic(TopicName.ofProjectTopicName("[PROJECT]", "[TOPIC]").toString()) * .setPushConfig(PushConfig.newBuilder().build()) * .setAckDeadlineSeconds(2135351438) @@ -502,77 +498,6 @@ public final Subscription createSubscription(Subscription request) { return createSubscriptionCallable().call(request); } - // AUTO-GENERATED DOCUMENTATION AND METHOD - /** - * Creates a subscription to a given topic. See the <a - * href="https://cloud.google.com/pubsub/docs/admin#resource_names"> resource name - * rules</a>. If the subscription already exists, returns `ALREADY_EXISTS`. If the - * corresponding topic doesn't exist, returns `NOT_FOUND`. - * - *If the name is not provided in the request, the server will assign a random name for this - * subscription on the same project as the topic, conforming to the [resource name - * format](https://cloud.google.com/pubsub/docs/admin#resource_names). The generated name is - * populated in the returned Subscription object. Note that for REST API requests, you must - * specify a name in the request. - * - *
Sample code: - * - *
- * - * @param name Required. The name of the subscription. It must have the format - * `"projects/{project}/subscriptions/{subscription}"`. `{subscription}` must start with a - * letter, and contain only letters (`[A-Za-z]`), numbers (`[0-9]`), dashes (`-`), underscores - * (`_`), periods (`.`), tildes (`~`), plus (`+`) or percent signs (`%`). It must be between 3 - * and 255 characters in length, and it must not start with `"goog"`. - * @param topic Required. The name of the topic from which this subscription is receiving - * messages. Format is `projects/{project}/topics/{topic}`. The value of this field will be - * `_deleted-topic_` if the topic has been deleted. - * @param pushConfig If push delivery is used with this subscription, this field is used to - * configure it. An empty `pushConfig` signifies that the subscriber will pull and ack - * messages using API methods. - * @param ackDeadlineSeconds The approximate amount of time (on a best-effort basis) Pub/Sub waits - * for the subscriber to acknowledge receipt before resending the message. In the interval - * after the message is delivered and before it is acknowledged, it is considered to be - * <i>outstanding</i>. During that time period, the message will not be - * redelivered (on a best-effort basis). - *- * try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) { - * ProjectSubscriptionName name = ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]"); - * ProjectTopicName topic = ProjectTopicName.of("[PROJECT]", "[TOPIC]"); - * PushConfig pushConfig = PushConfig.newBuilder().build(); - * int ackDeadlineSeconds = 0; - * Subscription response = subscriptionAdminClient.createSubscription(name, topic, pushConfig, ackDeadlineSeconds); - * } - *
For pull subscriptions, this value is used as the initial value for the ack deadline. To - * override this value for a given message, call `ModifyAckDeadline` with the corresponding - * `ack_id` if using non-streaming pull or send the `ack_id` in a - * `StreamingModifyAckDeadlineRequest` if using streaming pull. The minimum custom deadline - * you can specify is 10 seconds. The maximum custom deadline you can specify is 600 seconds - * (10 minutes). If this parameter is 0, a default value of 10 seconds is used. - *
For push delivery, this value is also used to set the request timeout for the call to - * the push endpoint. - *
If the subscriber never acknowledges the message, the Pub/Sub system will eventually - * redeliver the message. - * @throws com.google.api.gax.rpc.ApiException if the remote call fails - * @deprecated Use {@link #createSubscription(ProjectSubscriptionName, TopicName, PushConfig, - * int)} instead. - */ - @Deprecated - public final Subscription createSubscription( - ProjectSubscriptionName name, - ProjectTopicName topic, - PushConfig pushConfig, - int ackDeadlineSeconds) { - Subscription request = - Subscription.newBuilder() - .setName(name == null ? null : name.toString()) - .setTopic(topic == null ? null : topic.toString()) - .setPushConfig(pushConfig) - .setAckDeadlineSeconds(ackDeadlineSeconds) - .build(); - return createSubscription(request); - } - // AUTO-GENERATED DOCUMENTATION AND METHOD. /** * Creates a subscription to a given topic. See the [resource name rules] @@ -592,7 +517,7 @@ public final Subscription createSubscription( * try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) { * Subscription request = * Subscription.newBuilder() - * .setName(ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString()) + * .setName(SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString()) * .setTopic(TopicName.ofProjectTopicName("[PROJECT]", "[TOPIC]").toString()) * .setPushConfig(PushConfig.newBuilder().build()) * .setAckDeadlineSeconds(2135351438) @@ -626,7 +551,7 @@ public final UnaryCallable
createSubscriptionCallabl * * {@code * try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) { - * ProjectSubscriptionName subscription = ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]"); + * SubscriptionName subscription = SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]"); * Subscription response = subscriptionAdminClient.getSubscription(subscription); * } * }@@ -635,7 +560,7 @@ public final UnaryCallablecreateSubscriptionCallabl * `projects/{project}/subscriptions/{sub}`. * @throws com.google.api.gax.rpc.ApiException if the remote call fails */ - public final Subscription getSubscription(ProjectSubscriptionName subscription) { + public final Subscription getSubscription(SubscriptionName subscription) { GetSubscriptionRequest request = GetSubscriptionRequest.newBuilder() .setSubscription(subscription == null ? null : subscription.toString()) @@ -651,7 +576,7 @@ public final Subscription getSubscription(ProjectSubscriptionName subscription) * * {@code * try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) { - * String subscription = ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString(); + * String subscription = SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString(); * Subscription response = subscriptionAdminClient.getSubscription(subscription); * } * }@@ -676,7 +601,7 @@ public final Subscription getSubscription(String subscription) { * try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) { * GetSubscriptionRequest request = * GetSubscriptionRequest.newBuilder() - * .setSubscription(ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString()) + * .setSubscription(SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString()) * .build(); * Subscription response = subscriptionAdminClient.getSubscription(request); * } @@ -699,7 +624,7 @@ public final Subscription getSubscription(GetSubscriptionRequest request) { * try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) { * GetSubscriptionRequest request = * GetSubscriptionRequest.newBuilder() - * .setSubscription(ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString()) + * .setSubscription(SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString()) * .build(); * ApiFuturefuture = * subscriptionAdminClient.getSubscriptionCallable().futureCall(request); @@ -855,7 +780,7 @@ public final ListSubscriptionsPagedResponse listSubscriptions(ListSubscriptionsR * .setPageSize(883849137) * .setPageToken("pageToken873572522") * .build(); - * ApiFuture future = + * ApiFuture future = * subscriptionAdminClient.listSubscriptionsPagedCallable().futureCall(request); * // Do something. * for (Subscription element : future.get().iterateAll()) { @@ -886,7 +811,7 @@ public final ListSubscriptionsPagedResponse listSubscriptions(ListSubscriptionsR * while (true) { * ListSubscriptionsResponse response = * subscriptionAdminClient.listSubscriptionsCallable().call(request); - * for (Subscription element : response.getSubscriptionsList()) { + * for (Subscription element : response.getResponsesList()) { * // doThingsWith(element); * } * String nextPageToken = response.getNextPageToken(); @@ -915,7 +840,7 @@ public final ListSubscriptionsPagedResponse listSubscriptions(ListSubscriptionsR * * {@code * try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) { - * ProjectSubscriptionName subscription = ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]"); + * SubscriptionName subscription = SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]"); * subscriptionAdminClient.deleteSubscription(subscription); * } * }@@ -924,7 +849,7 @@ public final ListSubscriptionsPagedResponse listSubscriptions(ListSubscriptionsR * `projects/{project}/subscriptions/{sub}`. * @throws com.google.api.gax.rpc.ApiException if the remote call fails */ - public final void deleteSubscription(ProjectSubscriptionName subscription) { + public final void deleteSubscription(SubscriptionName subscription) { DeleteSubscriptionRequest request = DeleteSubscriptionRequest.newBuilder() .setSubscription(subscription == null ? null : subscription.toString()) @@ -943,7 +868,7 @@ public final void deleteSubscription(ProjectSubscriptionName subscription) { * *{@code * try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) { - * String subscription = ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString(); + * String subscription = SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString(); * subscriptionAdminClient.deleteSubscription(subscription); * } * }@@ -971,7 +896,7 @@ public final void deleteSubscription(String subscription) { * try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) { * DeleteSubscriptionRequest request = * DeleteSubscriptionRequest.newBuilder() - * .setSubscription(ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString()) + * .setSubscription(SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString()) * .build(); * subscriptionAdminClient.deleteSubscription(request); * } @@ -997,7 +922,7 @@ public final void deleteSubscription(DeleteSubscriptionRequest request) { * try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) { * DeleteSubscriptionRequest request = * DeleteSubscriptionRequest.newBuilder() - * .setSubscription(ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString()) + * .setSubscription(SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString()) * .build(); * ApiFuturefuture = * subscriptionAdminClient.deleteSubscriptionCallable().futureCall(request); @@ -1021,7 +946,7 @@ public final UnaryCallable deleteSubscriptionC * * {@code * try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) { - * ProjectSubscriptionName subscription = ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]"); + * SubscriptionName subscription = SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]"); * ListackIds = new ArrayList<>(); * int ackDeadlineSeconds = 2135351438; * subscriptionAdminClient.modifyAckDeadline(subscription, ackIds, ackDeadlineSeconds); @@ -1040,8 +965,8 @@ public final UnaryCallable deleteSubscriptionC * 600 seconds (10 minutes). * @throws com.google.api.gax.rpc.ApiException if the remote call fails */ - /* package-private */ final void modifyAckDeadline( - ProjectSubscriptionName subscription, List ackIds, int ackDeadlineSeconds) { + public final void modifyAckDeadline( + SubscriptionName subscription, List ackIds, int ackDeadlineSeconds) { ModifyAckDeadlineRequest request = ModifyAckDeadlineRequest.newBuilder() .setSubscription(subscription == null ? null : subscription.toString()) @@ -1062,7 +987,7 @@ public final UnaryCallable deleteSubscriptionC * * {@code * try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) { - * String subscription = ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString(); + * String subscription = SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString(); * ListackIds = new ArrayList<>(); * int ackDeadlineSeconds = 2135351438; * subscriptionAdminClient.modifyAckDeadline(subscription, ackIds, ackDeadlineSeconds); @@ -1105,7 +1030,7 @@ public final void modifyAckDeadline( * try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) { * ModifyAckDeadlineRequest request = * ModifyAckDeadlineRequest.newBuilder() - * .setSubscription(ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString()) + * .setSubscription(SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString()) * .addAllAckIds(new ArrayList ()) * .setAckDeadlineSeconds(2135351438) * .build(); @@ -1133,7 +1058,7 @@ public final void modifyAckDeadline(ModifyAckDeadlineRequest request) { * try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) { * ModifyAckDeadlineRequest request = * ModifyAckDeadlineRequest.newBuilder() - * .setSubscription(ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString()) + * .setSubscription(SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString()) * .addAllAckIds(new ArrayList ()) * .setAckDeadlineSeconds(2135351438) * .build(); @@ -1160,7 +1085,7 @@ public final UnaryCallable modifyAckDeadlineCal * * {@code * try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) { - * ProjectSubscriptionName subscription = ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]"); + * SubscriptionName subscription = SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]"); * ListackIds = new ArrayList<>(); * subscriptionAdminClient.acknowledge(subscription, ackIds); * } @@ -1172,7 +1097,7 @@ public final UnaryCallable modifyAckDeadlineCal * returned by the Pub/Sub system in the `Pull` response. Must not be empty. * @throws com.google.api.gax.rpc.ApiException if the remote call fails */ - public final void acknowledge(ProjectSubscriptionName subscription, List ackIds) { + public final void acknowledge(SubscriptionName subscription, List ackIds) { AcknowledgeRequest request = AcknowledgeRequest.newBuilder() .setSubscription(subscription == null ? null : subscription.toString()) @@ -1193,7 +1118,7 @@ public final void acknowledge(ProjectSubscriptionName subscription, List * * {@code * try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) { - * String subscription = ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString(); + * String subscription = SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString(); * ListackIds = new ArrayList<>(); * subscriptionAdminClient.acknowledge(subscription, ackIds); * } @@ -1225,7 +1150,7 @@ public final void acknowledge(String subscription, List ackIds) { * try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) { * AcknowledgeRequest request = * AcknowledgeRequest.newBuilder() - * .setSubscription(ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString()) + * .setSubscription(SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString()) * .addAllAckIds(new ArrayList ()) * .build(); * subscriptionAdminClient.acknowledge(request); @@ -1253,7 +1178,7 @@ public final void acknowledge(AcknowledgeRequest request) { * try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) { * AcknowledgeRequest request = * AcknowledgeRequest.newBuilder() - * .setSubscription(ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString()) + * .setSubscription(SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString()) * .addAllAckIds(new ArrayList ()) * .build(); * ApiFuture future = subscriptionAdminClient.acknowledgeCallable().futureCall(request); @@ -1275,7 +1200,7 @@ public final UnaryCallable acknowledgeCallable() { * * {@code * try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) { - * ProjectSubscriptionName subscription = ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]"); + * SubscriptionName subscription = SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]"); * int maxMessages = 496131527; * PullResponse response = subscriptionAdminClient.pull(subscription, maxMessages); * } @@ -1287,7 +1212,7 @@ public final UnaryCallableacknowledgeCallable() { * a positive integer. The Pub/Sub system may return fewer than the number specified. * @throws com.google.api.gax.rpc.ApiException if the remote call fails */ - public final PullResponse pull(ProjectSubscriptionName subscription, int maxMessages) { + public final PullResponse pull(SubscriptionName subscription, int maxMessages) { PullRequest request = PullRequest.newBuilder() .setSubscription(subscription == null ? null : subscription.toString()) @@ -1305,7 +1230,7 @@ public final PullResponse pull(ProjectSubscriptionName subscription, int maxMess * * {@code * try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) { - * String subscription = ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString(); + * String subscription = SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString(); * int maxMessages = 496131527; * PullResponse response = subscriptionAdminClient.pull(subscription, maxMessages); * } @@ -1332,7 +1257,7 @@ public final PullResponse pull(String subscription, int maxMessages) { * *{@code * try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) { - * ProjectSubscriptionName subscription = ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]"); + * SubscriptionName subscription = SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]"); * boolean returnImmediately = true; * int maxMessages = 496131527; * PullResponse response = @@ -1352,8 +1277,8 @@ public final PullResponse pull(String subscription, int maxMessages) { * a positive integer. The Pub/Sub system may return fewer than the number specified. * @throws com.google.api.gax.rpc.ApiException if the remote call fails */ - /* package-private */ final PullResponse pull( - ProjectSubscriptionName subscription, boolean returnImmediately, int maxMessages) { + public final PullResponse pull( + SubscriptionName subscription, boolean returnImmediately, int maxMessages) { PullRequest request = PullRequest.newBuilder() .setSubscription(subscription == null ? null : subscription.toString()) @@ -1372,7 +1297,7 @@ public final PullResponse pull(String subscription, int maxMessages) { * *{@code * try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) { - * String subscription = ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString(); + * String subscription = SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString(); * boolean returnImmediately = true; * int maxMessages = 496131527; * PullResponse response = @@ -1413,7 +1338,7 @@ public final PullResponse pull(String subscription, boolean returnImmediately, i * try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) { * PullRequest request = * PullRequest.newBuilder() - * .setSubscription(ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString()) + * .setSubscription(SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString()) * .setReturnImmediately(true) * .setMaxMessages(496131527) * .build(); @@ -1439,7 +1364,7 @@ public final PullResponse pull(PullRequest request) { * try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) { * PullRequest request = * PullRequest.newBuilder() - * .setSubscription(ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString()) + * .setSubscription(SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString()) * .setReturnImmediately(true) * .setMaxMessages(496131527) * .build(); @@ -1470,7 +1395,7 @@ public final UnaryCallablepullCallable() { * subscriptionAdminClient.streamingPullCallable().call(); * StreamingPullRequest request = * StreamingPullRequest.newBuilder() - * .setSubscription(ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString()) + * .setSubscription(SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString()) * .addAllAckIds(new ArrayList ()) * .addAllModifyDeadlineSeconds(new ArrayList ()) * .addAllModifyDeadlineAckIds(new ArrayList ()) @@ -1504,7 +1429,7 @@ public final UnaryCallable pullCallable() { * * {@code * try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) { - * ProjectSubscriptionName subscription = ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]"); + * SubscriptionName subscription = SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]"); * PushConfig pushConfig = PushConfig.newBuilder().build(); * subscriptionAdminClient.modifyPushConfig(subscription, pushConfig); * } @@ -1518,7 +1443,7 @@ public final UnaryCallablepullCallable() { * pausing the subscription if `Pull` or `StreamingPull` is not called. * @throws com.google.api.gax.rpc.ApiException if the remote call fails */ - public final void modifyPushConfig(ProjectSubscriptionName subscription, PushConfig pushConfig) { + public final void modifyPushConfig(SubscriptionName subscription, PushConfig pushConfig) { ModifyPushConfigRequest request = ModifyPushConfigRequest.newBuilder() .setSubscription(subscription == null ? null : subscription.toString()) @@ -1540,7 +1465,7 @@ public final void modifyPushConfig(ProjectSubscriptionName subscription, PushCon * * {@code * try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) { - * String subscription = ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString(); + * String subscription = SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString(); * PushConfig pushConfig = PushConfig.newBuilder().build(); * subscriptionAdminClient.modifyPushConfig(subscription, pushConfig); * } @@ -1578,7 +1503,7 @@ public final void modifyPushConfig(String subscription, PushConfig pushConfig) { * try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) { * ModifyPushConfigRequest request = * ModifyPushConfigRequest.newBuilder() - * .setSubscription(ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString()) + * .setSubscription(SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString()) * .setPushConfig(PushConfig.newBuilder().build()) * .build(); * subscriptionAdminClient.modifyPushConfig(request); @@ -1607,7 +1532,7 @@ public final void modifyPushConfig(ModifyPushConfigRequest request) { * try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) { * ModifyPushConfigRequest request = * ModifyPushConfigRequest.newBuilder() - * .setSubscription(ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString()) + * .setSubscription(SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString()) * .setPushConfig(PushConfig.newBuilder().build()) * .build(); * ApiFuturefuture = @@ -1632,7 +1557,7 @@ public final UnaryCallable modifyPushConfigCalla * * {@code * try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) { - * ProjectSnapshotName snapshot = ProjectSnapshotName.of("[PROJECT]", "[SNAPSHOT]"); + * SnapshotName snapshot = SnapshotName.of("[PROJECT]", "[SNAPSHOT]"); * Snapshot response = subscriptionAdminClient.getSnapshot(snapshot); * } * }@@ -1641,7 +1566,7 @@ public final UnaryCallablemodifyPushConfigCalla * `projects/{project}/snapshots/{snap}`. * @throws com.google.api.gax.rpc.ApiException if the remote call fails */ - public final Snapshot getSnapshot(ProjectSnapshotName snapshot) { + public final Snapshot getSnapshot(SnapshotName snapshot) { GetSnapshotRequest request = GetSnapshotRequest.newBuilder() .setSnapshot(snapshot == null ? null : snapshot.toString()) @@ -1660,7 +1585,7 @@ public final Snapshot getSnapshot(ProjectSnapshotName snapshot) { * * {@code * try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) { - * String snapshot = ProjectSnapshotName.of("[PROJECT]", "[SNAPSHOT]").toString(); + * String snapshot = SnapshotName.of("[PROJECT]", "[SNAPSHOT]").toString(); * Snapshot response = subscriptionAdminClient.getSnapshot(snapshot); * } * }@@ -1687,7 +1612,7 @@ public final Snapshot getSnapshot(String snapshot) { * try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) { * GetSnapshotRequest request = * GetSnapshotRequest.newBuilder() - * .setSnapshot(ProjectSnapshotName.of("[PROJECT]", "[SNAPSHOT]").toString()) + * .setSnapshot(SnapshotName.of("[PROJECT]", "[SNAPSHOT]").toString()) * .build(); * Snapshot response = subscriptionAdminClient.getSnapshot(request); * } @@ -1713,7 +1638,7 @@ public final Snapshot getSnapshot(GetSnapshotRequest request) { * try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) { * GetSnapshotRequest request = * GetSnapshotRequest.newBuilder() - * .setSnapshot(ProjectSnapshotName.of("[PROJECT]", "[SNAPSHOT]").toString()) + * .setSnapshot(SnapshotName.of("[PROJECT]", "[SNAPSHOT]").toString()) * .build(); * ApiFuturefuture = * subscriptionAdminClient.getSnapshotCallable().futureCall(request); @@ -1830,7 +1755,7 @@ public final ListSnapshotsPagedResponse listSnapshots(ListSnapshotsRequest reque * .setPageSize(883849137) * .setPageToken("pageToken873572522") * .build(); - * ApiFuture future = + * ApiFuture future = * subscriptionAdminClient.listSnapshotsPagedCallable().futureCall(request); * // Do something. * for (Snapshot element : future.get().iterateAll()) { @@ -1864,7 +1789,7 @@ public final ListSnapshotsPagedResponse listSnapshots(ListSnapshotsRequest reque * while (true) { * ListSnapshotsResponse response = * subscriptionAdminClient.listSnapshotsCallable().call(request); - * for (Snapshot element : response.getSnapshotsList()) { + * for (Snapshot element : response.getResponsesList()) { * // doThingsWith(element); * } * String nextPageToken = response.getNextPageToken(); @@ -1900,8 +1825,8 @@ public final UnaryCallable listSnap * * {@code * try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) { - * ProjectSnapshotName name = ProjectSnapshotName.of("[PROJECT]", "[SNAPSHOT]"); - * ProjectSubscriptionName subscription = ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]"); + * SnapshotName name = SnapshotName.of("[PROJECT]", "[SNAPSHOT]"); + * SubscriptionName subscription = SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]"); * Snapshot response = subscriptionAdminClient.createSnapshot(name, subscription); * } * }@@ -1920,8 +1845,7 @@ public final UnaryCallablelistSnap * `projects/{project}/subscriptions/{sub}`. * @throws com.google.api.gax.rpc.ApiException if the remote call fails */ - public final Snapshot createSnapshot( - ProjectSnapshotName name, ProjectSubscriptionName subscription) { + public final Snapshot createSnapshot(SnapshotName name, SubscriptionName subscription) { CreateSnapshotRequest request = CreateSnapshotRequest.newBuilder() .setName(name == null ? null : name.toString()) @@ -1949,8 +1873,8 @@ public final Snapshot createSnapshot( * * {@code * try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) { - * ProjectSnapshotName name = ProjectSnapshotName.of("[PROJECT]", "[SNAPSHOT]"); - * String subscription = ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString(); + * SnapshotName name = SnapshotName.of("[PROJECT]", "[SNAPSHOT]"); + * String subscription = SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString(); * Snapshot response = subscriptionAdminClient.createSnapshot(name, subscription); * } * }@@ -1969,7 +1893,7 @@ public final Snapshot createSnapshot( * `projects/{project}/subscriptions/{sub}`. * @throws com.google.api.gax.rpc.ApiException if the remote call fails */ - public final Snapshot createSnapshot(ProjectSnapshotName name, String subscription) { + public final Snapshot createSnapshot(SnapshotName name, String subscription) { CreateSnapshotRequest request = CreateSnapshotRequest.newBuilder() .setName(name == null ? null : name.toString()) @@ -1997,8 +1921,8 @@ public final Snapshot createSnapshot(ProjectSnapshotName name, String subscripti * *{@code * try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) { - * String name = ProjectSnapshotName.of("[PROJECT]", "[SNAPSHOT]").toString(); - * ProjectSubscriptionName subscription = ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]"); + * String name = SnapshotName.of("[PROJECT]", "[SNAPSHOT]").toString(); + * SubscriptionName subscription = SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]"); * Snapshot response = subscriptionAdminClient.createSnapshot(name, subscription); * } * }@@ -2017,7 +1941,7 @@ public final Snapshot createSnapshot(ProjectSnapshotName name, String subscripti * `projects/{project}/subscriptions/{sub}`. * @throws com.google.api.gax.rpc.ApiException if the remote call fails */ - public final Snapshot createSnapshot(String name, ProjectSubscriptionName subscription) { + public final Snapshot createSnapshot(String name, SubscriptionName subscription) { CreateSnapshotRequest request = CreateSnapshotRequest.newBuilder() .setName(name) @@ -2045,8 +1969,8 @@ public final Snapshot createSnapshot(String name, ProjectSubscriptionName subscr * *{@code * try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) { - * String name = ProjectSnapshotName.of("[PROJECT]", "[SNAPSHOT]").toString(); - * String subscription = ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString(); + * String name = SnapshotName.of("[PROJECT]", "[SNAPSHOT]").toString(); + * String subscription = SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString(); * Snapshot response = subscriptionAdminClient.createSnapshot(name, subscription); * } * }@@ -2092,8 +2016,8 @@ public final Snapshot createSnapshot(String name, String subscription) { * try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) { * CreateSnapshotRequest request = * CreateSnapshotRequest.newBuilder() - * .setName(ProjectSnapshotName.of("[PROJECT]", "[SNAPSHOT]").toString()) - * .setSubscription(ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString()) + * .setName(SnapshotName.of("[PROJECT]", "[SNAPSHOT]").toString()) + * .setSubscription(SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString()) * .putAllLabels(new HashMap()) * .build(); * Snapshot response = subscriptionAdminClient.createSnapshot(request); @@ -2128,8 +2052,8 @@ public final Snapshot createSnapshot(CreateSnapshotRequest request) { * try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) { * CreateSnapshotRequest request = * CreateSnapshotRequest.newBuilder() - * .setName(ProjectSnapshotName.of("[PROJECT]", "[SNAPSHOT]").toString()) - * .setSubscription(ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString()) + * .setName(SnapshotName.of("[PROJECT]", "[SNAPSHOT]").toString()) + * .setSubscription(SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString()) * .putAllLabels(new HashMap ()) * .build(); * ApiFuture future = @@ -2211,7 +2135,7 @@ public final UnaryCallable updateSnapshotCallab * * {@code * try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) { - * ProjectSnapshotName snapshot = ProjectSnapshotName.of("[PROJECT]", "[SNAPSHOT]"); + * SnapshotName snapshot = SnapshotName.of("[PROJECT]", "[SNAPSHOT]"); * subscriptionAdminClient.deleteSnapshot(snapshot); * } * }@@ -2220,7 +2144,7 @@ public final UnaryCallableupdateSnapshotCallab * `projects/{project}/snapshots/{snap}`. * @throws com.google.api.gax.rpc.ApiException if the remote call fails */ - public final void deleteSnapshot(ProjectSnapshotName snapshot) { + public final void deleteSnapshot(SnapshotName snapshot) { DeleteSnapshotRequest request = DeleteSnapshotRequest.newBuilder() .setSnapshot(snapshot == null ? null : snapshot.toString()) @@ -2242,7 +2166,7 @@ public final void deleteSnapshot(ProjectSnapshotName snapshot) { * * {@code * try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) { - * String snapshot = ProjectSnapshotName.of("[PROJECT]", "[SNAPSHOT]").toString(); + * String snapshot = SnapshotName.of("[PROJECT]", "[SNAPSHOT]").toString(); * subscriptionAdminClient.deleteSnapshot(snapshot); * } * }@@ -2273,7 +2197,7 @@ public final void deleteSnapshot(String snapshot) { * try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) { * DeleteSnapshotRequest request = * DeleteSnapshotRequest.newBuilder() - * .setSnapshot(ProjectSnapshotName.of("[PROJECT]", "[SNAPSHOT]").toString()) + * .setSnapshot(SnapshotName.of("[PROJECT]", "[SNAPSHOT]").toString()) * .build(); * subscriptionAdminClient.deleteSnapshot(request); * } @@ -2302,7 +2226,7 @@ public final void deleteSnapshot(DeleteSnapshotRequest request) { * try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) { * DeleteSnapshotRequest request = * DeleteSnapshotRequest.newBuilder() - * .setSnapshot(ProjectSnapshotName.of("[PROJECT]", "[SNAPSHOT]").toString()) + * .setSnapshot(SnapshotName.of("[PROJECT]", "[SNAPSHOT]").toString()) * .build(); * ApiFuturefuture = * subscriptionAdminClient.deleteSnapshotCallable().futureCall(request); @@ -2330,7 +2254,7 @@ public final UnaryCallable deleteSnapshotCallable( * try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) { * SeekRequest request = * SeekRequest.newBuilder() - * .setSubscription(ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString()) + * .setSubscription(SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString()) * .build(); * SeekResponse response = subscriptionAdminClient.seek(request); * } @@ -2358,7 +2282,7 @@ public final SeekResponse seek(SeekRequest request) { * try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) { * SeekRequest request = * SeekRequest.newBuilder() - * .setSubscription(ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString()) + * .setSubscription(SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString()) * .build(); * ApiFuture future = subscriptionAdminClient.seekCallable().futureCall(request); * // Do something. @@ -2396,37 +2320,6 @@ public final Policy setIamPolicy(SetIamPolicyRequest request) { return setIamPolicyCallable().call(request); } - // AUTO-GENERATED DOCUMENTATION AND METHOD - /** - * Sets the access control policy on the specified resource. Replaces any existing policy. - * - * Can return Public Errors: NOT_FOUND, INVALID_ARGUMENT and PERMISSION_DENIED - * - *
Sample code: - * - *
- * - * @param resource REQUIRED: The resource for which the policy is being specified. See the - * operation documentation for the appropriate value for this field. - * @param policy REQUIRED: The complete policy to be applied to the `resource`. The size of the - * policy is limited to a few 10s of KB. An empty policy is a valid policy but certain Cloud - * Platform services (such as Projects) might reject them. - * @throws com.google.api.gax.rpc.ApiException if the remote call fails - * @deprecated Use {@link #setIamPolicy(SetIamPolicyRequest)} instead. - */ - @Deprecated - public final Policy setIamPolicy(String resource, Policy policy) { - SetIamPolicyRequest request = - SetIamPolicyRequest.newBuilder().setResource(resource).setPolicy(policy).build(); - return setIamPolicy(request); - } - // AUTO-GENERATED DOCUMENTATION AND METHOD. /** * Sets the access control policy on the specified resource. Replacesany existing policy. @@ -2477,31 +2370,6 @@ public final Policy getIamPolicy(GetIamPolicyRequest request) { return getIamPolicyCallable().call(request); } - // AUTO-GENERATED DOCUMENTATION AND METHOD - /** - * Gets the access control policy for a resource. Returns an empty policy if the resource exists - * and does not have a policy set. - * - *- * try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) { - * String formattedResource = ProjectTopicName.format("[PROJECT]", "[TOPIC]"); - * Policy policy = Policy.newBuilder().build(); - * Policy response = subscriptionAdminClient.setIamPolicy(formattedResource, policy); - * } - *
Sample code: - * - *
- * - * @param resource REQUIRED: The resource for which the policy is being requested. See the - * operation documentation for the appropriate value for this field. - * @throws com.google.api.gax.rpc.ApiException if the remote call fails - * @deprecated Use {@link #getIamPolicy(GetIamPolicyRequest)} instead. - */ - @Deprecated - public final Policy getIamPolicy(String resource) { - GetIamPolicyRequest request = GetIamPolicyRequest.newBuilder().setResource(resource).build(); - return getIamPolicy(request); - } - // AUTO-GENERATED DOCUMENTATION AND METHOD. /** * Gets the access control policy for a resource. Returns an empty policyif the resource exists @@ -2555,44 +2423,6 @@ public final TestIamPermissionsResponse testIamPermissions(TestIamPermissionsReq return testIamPermissionsCallable().call(request); } - // AUTO-GENERATED DOCUMENTATION AND METHOD - /** - * Returns permissions that a caller has on the specified resource. If the resource does not - * exist, this will return an empty set of permissions, not a NOT_FOUND error. - * - *- * try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) { - * String formattedResource = ProjectTopicName.format("[PROJECT]", "[TOPIC]"); - * Policy response = subscriptionAdminClient.getIamPolicy(formattedResource); - * } - *
Note: This operation is designed to be used for building permission-aware UIs and - * command-line tools, not for authorization checking. This operation may "fail open" without - * warning. - * - *
Sample code: - * - *
- * - * @param resource REQUIRED: The resource for which the policy detail is being requested. See the - * operation documentation for the appropriate value for this field. - * @param permissions The set of permissions to check for the `resource`. Permissions with - * wildcards (such as '*' or 'storage.*') are not allowed. For more information see - * [IAM Overview](https://cloud.google.com/iam/docs/overview#permissions). - * @throws com.google.api.gax.rpc.ApiException if the remote call fails - * @deprecated Use {@link #testIamPermissions(TestIamPermissionsRequest)} instead. - */ - @Deprecated - public final TestIamPermissionsResponse testIamPermissions( - String resource, List- * try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) { - * String formattedResource = ProjectTopicName.format("[PROJECT]", "[TOPIC]"); - * List<String> permissions = new ArrayList<>(); - * TestIamPermissionsResponse response = subscriptionAdminClient.testIamPermissions(formattedResource, permissions); - * } - *
permissions) { - TestIamPermissionsRequest request = - TestIamPermissionsRequest.newBuilder() - .setResource(resource) - .addAllPermissions(permissions) - .build(); - return testIamPermissions(request); - } - // AUTO-GENERATED DOCUMENTATION AND METHOD. /** * Returns permissions that a caller has on the specified resource. If theresource does not exist, @@ -2655,10 +2485,7 @@ public boolean awaitTermination(long duration, TimeUnit unit) throws Interrupted public static class ListSubscriptionsPagedResponse extends AbstractPagedListResponse< - ListSubscriptionsRequest, - ListSubscriptionsResponse, - Subscription, - ListSubscriptionsPage, + ListSubscriptionsRequest, ListSubscriptionsResponse, Subscription, ListSubscriptionsPage, ListSubscriptionsFixedSizeCollection> { public static ApiFuture createAsync( @@ -2679,9 +2506,7 @@ private ListSubscriptionsPagedResponse(ListSubscriptionsPage page) { public static class ListSubscriptionsPage extends AbstractPage< - ListSubscriptionsRequest, - ListSubscriptionsResponse, - Subscription, + ListSubscriptionsRequest, ListSubscriptionsResponse, Subscription, ListSubscriptionsPage> { private ListSubscriptionsPage( @@ -2711,10 +2536,7 @@ public ApiFuture createPageAsync( public static class ListSubscriptionsFixedSizeCollection extends AbstractFixedSizeCollection< - ListSubscriptionsRequest, - ListSubscriptionsResponse, - Subscription, - ListSubscriptionsPage, + ListSubscriptionsRequest, ListSubscriptionsResponse, Subscription, ListSubscriptionsPage, ListSubscriptionsFixedSizeCollection> { private ListSubscriptionsFixedSizeCollection( @@ -2735,10 +2557,7 @@ protected ListSubscriptionsFixedSizeCollection createCollection( public static class ListSnapshotsPagedResponse extends AbstractPagedListResponse< - ListSnapshotsRequest, - ListSnapshotsResponse, - Snapshot, - ListSnapshotsPage, + ListSnapshotsRequest, ListSnapshotsResponse, Snapshot, ListSnapshotsPage, ListSnapshotsFixedSizeCollection> { public static ApiFuture createAsync( @@ -2788,10 +2607,7 @@ public ApiFuture createPageAsync( public static class ListSnapshotsFixedSizeCollection extends AbstractFixedSizeCollection< - ListSnapshotsRequest, - ListSnapshotsResponse, - Snapshot, - ListSnapshotsPage, + ListSnapshotsRequest, ListSnapshotsResponse, Snapshot, ListSnapshotsPage, ListSnapshotsFixedSizeCollection> { private ListSnapshotsFixedSizeCollection(List pages, int collectionSize) { diff --git a/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/SubscriptionAdminSettings.java b/owl-bot-staging/v1/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/SubscriptionAdminSettings.java similarity index 98% rename from google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/SubscriptionAdminSettings.java rename to owl-bot-staging/v1/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/SubscriptionAdminSettings.java index a90bfd141..578102ebe 100644 --- a/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/SubscriptionAdminSettings.java +++ b/owl-bot-staging/v1/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/SubscriptionAdminSettings.java @@ -29,6 +29,7 @@ import com.google.api.gax.rpc.ClientSettings; import com.google.api.gax.rpc.PagedCallSettings; import com.google.api.gax.rpc.StreamingCallSettings; +import com.google.api.gax.rpc.StubSettings; import com.google.api.gax.rpc.TransportChannelProvider; import com.google.api.gax.rpc.UnaryCallSettings; import com.google.cloud.pubsub.v1.stub.SubscriberStubSettings; @@ -71,9 +72,9 @@ * The default instance has everything set to sensible defaults: * *
- *
* *- The default service address (pubsub.googleapis.com) and default port (443) are used. - *
- Credentials are acquired automatically through Application Default Credentials. - *
- Retries are configured for idempotent methods but not for non-idempotent methods. + *
- The default service address (pubsub.googleapis.com) and default port (443) are used. + *
- Credentials are acquired automatically through Application Default Credentials. + *
- Retries are configured for idempotent methods but not for non-idempotent methods. *
The builder of this class is recursive, so contained classes are themselves builders. When diff --git a/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/TopicAdminClient.java b/owl-bot-staging/v1/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/TopicAdminClient.java similarity index 82% rename from google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/TopicAdminClient.java rename to owl-bot-staging/v1/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/TopicAdminClient.java index 1a9ba2887..dfbbe0ebe 100644 --- a/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/TopicAdminClient.java +++ b/owl-bot-staging/v1/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/TopicAdminClient.java @@ -27,8 +27,6 @@ import com.google.api.gax.rpc.UnaryCallable; import com.google.cloud.pubsub.v1.stub.PublisherStub; import com.google.cloud.pubsub.v1.stub.PublisherStubSettings; -import com.google.common.base.Function; -import com.google.common.collect.Iterables; import com.google.common.util.concurrent.MoreExecutors; import com.google.iam.v1.GetIamPolicyRequest; import com.google.iam.v1.Policy; @@ -47,8 +45,6 @@ import com.google.pubsub.v1.ListTopicsRequest; import com.google.pubsub.v1.ListTopicsResponse; import com.google.pubsub.v1.ProjectName; -import com.google.pubsub.v1.ProjectSubscriptionName; -import com.google.pubsub.v1.ProjectTopicName; import com.google.pubsub.v1.PublishRequest; import com.google.pubsub.v1.PublishResponse; import com.google.pubsub.v1.PubsubMessage; @@ -82,13 +78,13 @@ * methods: * *
- *
* @@ -224,35 +220,6 @@ public final Topic createTopic(String name) { return createTopic(request); } - // AUTO-GENERATED DOCUMENTATION AND METHOD - /** - * Creates the given topic with the given name. See the <a - * href="https://cloud.google.com/pubsub/docs/admin#resource_names"> resource name - * rules</a>. - * - *- A "flattened" method. With this type of method, the fields of the request type have been + *
- A "flattened" method. With this type of method, the fields of the request type have been * converted into function parameters. It may be the case that not all fields are available as * parameters, and not every API method will have a flattened method entry point. - *
- A "request object" method. This type of method only takes one parameter, a request object, + *
- A "request object" method. This type of method only takes one parameter, a request object, * which must be constructed before the call. Not every API method will have a request object * method. - *
- A "callable" method. This type of method takes no parameters and returns an immutable API + *
- A "callable" method. This type of method takes no parameters and returns an immutable API * callable object, which can be used to initiate calls to the service. *
Sample code: - * - *
- * - * @param name Required. The name of the topic. It must have the format - * `"projects/{project}/topics/{topic}"`. `{topic}` must start with a letter, and contain only - * letters (`[A-Za-z]`), numbers (`[0-9]`), dashes (`-`), underscores (`_`), periods (`.`), - * tildes (`~`), plus (`+`) or percent signs (`%`). It must be between 3 and 255 characters in - * length, and it must not start with `"goog"`. - * @throws com.google.api.gax.rpc.ApiException if the remote call fails - * @deprecated Use {@link #createTopic(TopicName)} instead. - */ - @Deprecated - public final Topic createTopic(ProjectTopicName name) { - Topic request = Topic.newBuilder().setName(name == null ? null : name.toString()).build(); - return createTopic(request); - } - // AUTO-GENERATED DOCUMENTATION AND METHOD. /** * Creates the given topic with the given name. See the [resource name rules] @@ -504,31 +471,6 @@ public final Topic getTopic(String topic) { return getTopic(request); } - // AUTO-GENERATED DOCUMENTATION AND METHOD - /** - * Gets the configuration of a topic. - * - *- * try (TopicAdminClient topicAdminClient = TopicAdminClient.create()) { - * ProjectTopicName name = ProjectTopicName.of("[PROJECT]", "[TOPIC]"); - * Topic response = topicAdminClient.createTopic(name); - * } - *
Sample code: - * - *
- * - * @param topic Required. The name of the topic to get. Format is - * `projects/{project}/topics/{topic}`. - * @throws com.google.api.gax.rpc.ApiException if the remote call fails - * @deprecated Use {@link #getTopic(TopicName)} instead. - */ - @Deprecated - public final Topic getTopic(ProjectTopicName topic) { - GetTopicRequest request = - GetTopicRequest.newBuilder().setTopic(topic == null ? null : topic.toString()).build(); - return getTopic(request); - } - // AUTO-GENERATED DOCUMENTATION AND METHOD. /** * Gets the configuration of a topic. @@ -666,7 +608,7 @@ public final ListTopicsPagedResponse listTopics(ListTopicsRequest request) { * .setPageSize(883849137) * .setPageToken("pageToken873572522") * .build(); - * ApiFuture- * try (TopicAdminClient topicAdminClient = TopicAdminClient.create()) { - * ProjectTopicName topic = ProjectTopicName.of("[PROJECT]", "[TOPIC]"); - * Topic response = topicAdminClient.getTopic(topic); - * } - *
future = topicAdminClient.listTopicsPagedCallable().futureCall(request); + * ApiFuture future = topicAdminClient.listTopicsPagedCallable().futureCall(request); * // Do something. * for (Topic element : future.get().iterateAll()) { * // doThingsWith(element); @@ -694,7 +636,7 @@ public final UnaryCallable listTopic * .build(); * while (true) { * ListTopicsResponse response = topicAdminClient.listTopicsCallable().call(request); - * for (Topic element : response.getTopicsList()) { + * for (Topic element : response.getResponsesList()) { * // doThingsWith(element); * } * String nextPageToken = response.getNextPageToken(); @@ -763,35 +705,6 @@ public final ListTopicSubscriptionsPagedResponse listTopicSubscriptions(String t return listTopicSubscriptions(request); } - // AUTO-GENERATED DOCUMENTATION AND METHOD - /** - * Lists the names of the subscriptions on this topic. - * - * Sample code: - * - *
- * - * @param topic Required. The name of the topic that subscriptions are attached to. Format is - * `projects/{project}/topics/{topic}`. - * @throws com.google.api.gax.rpc.ApiException if the remote call fails - * @deprecated Use {@link #listTopicSubscriptions(TopicName)} instead. - */ - @Deprecated - public final ListTopicSubscriptionsPagedResponse listTopicSubscriptions(ProjectTopicName topic) { - ListTopicSubscriptionsRequest request = - ListTopicSubscriptionsRequest.newBuilder() - .setTopic(topic == null ? null : topic.toString()) - .build(); - return listTopicSubscriptions(request); - } - // AUTO-GENERATED DOCUMENTATION AND METHOD. /** * Lists the names of the attached subscriptions on this topic. @@ -834,7 +747,7 @@ public final ListTopicSubscriptionsPagedResponse listTopicSubscriptions( * .setPageSize(883849137) * .setPageToken("pageToken873572522") * .build(); - * ApiFuture- * try (TopicAdminClient topicAdminClient = TopicAdminClient.create()) { - * ProjectTopicName topic = ProjectTopicName.of("[PROJECT]", "[TOPIC]"); - * for (ProjectSubscriptionName element : topicAdminClient.listTopicSubscriptions(topic).iterateAllAsProjectSubscriptionName()) { - * // doThingsWith(element); - * } - * } - *
future = + * ApiFuture future = * topicAdminClient.listTopicSubscriptionsPagedCallable().futureCall(request); * // Do something. * for (String element : future.get().iterateAll()) { @@ -865,7 +778,7 @@ public final ListTopicSubscriptionsPagedResponse listTopicSubscriptions( * while (true) { * ListTopicSubscriptionsResponse response = * topicAdminClient.listTopicSubscriptionsCallable().call(request); - * for (String element : response.getSubscriptionsList()) { + * for (String element : response.getResponsesList()) { * // doThingsWith(element); * } * String nextPageToken = response.getNextPageToken(); @@ -989,7 +902,7 @@ public final ListTopicSnapshotsPagedResponse listTopicSnapshots( * .setPageSize(883849137) * .setPageToken("pageToken873572522") * .build(); - * ApiFuture future = + * ApiFuture future = * topicAdminClient.listTopicSnapshotsPagedCallable().futureCall(request); * // Do something. * for (String element : future.get().iterateAll()) { @@ -1023,7 +936,7 @@ public final ListTopicSnapshotsPagedResponse listTopicSnapshots( * while (true) { * ListTopicSnapshotsResponse response = * topicAdminClient.listTopicSnapshotsCallable().call(request); - * for (String element : response.getSnapshotsList()) { + * for (String element : response.getResponsesList()) { * // doThingsWith(element); * } * String nextPageToken = response.getNextPageToken(); @@ -1092,34 +1005,6 @@ public final void deleteTopic(String topic) { deleteTopic(request); } - // AUTO-GENERATED DOCUMENTATION AND METHOD - /** - * Deletes the topic with the given name. Returns `NOT_FOUND` if the topic does not exist. After a - * topic is deleted, a new topic may be created with the same name; this is an entirely new topic - * with none of the old configuration or subscriptions. Existing subscriptions to this topic are - * not deleted, but their `topic` field is set to `_deleted-topic_`. - * - * Sample code: - * - *
- * - * @param topic Required. Name of the topic to delete. Format is - * `projects/{project}/topics/{topic}`. - * @throws com.google.api.gax.rpc.ApiException if the remote call fails - * @deprecated Use {@link #deleteTopic(TopicName)} instead. - */ - @Deprecated - public final void deleteTopic(ProjectTopicName topic) { - DeleteTopicRequest request = - DeleteTopicRequest.newBuilder().setTopic(topic == null ? null : topic.toString()).build(); - deleteTopic(request); - } - // AUTO-GENERATED DOCUMENTATION AND METHOD. /** * Deletes the topic with the given name. Returns `NOT_FOUND` if the topic does not exist. After a @@ -1183,7 +1068,7 @@ public final UnaryCallable- * try (TopicAdminClient topicAdminClient = TopicAdminClient.create()) { - * ProjectTopicName topic = ProjectTopicName.of("[PROJECT]", "[TOPIC]"); - * topicAdminClient.deleteTopic(topic); - * } - *
deleteTopicCallable() { * try (TopicAdminClient topicAdminClient = TopicAdminClient.create()) { * DetachSubscriptionRequest request = * DetachSubscriptionRequest.newBuilder() - * .setSubscription(ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString()) + * .setSubscription(SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString()) * .build(); * DetachSubscriptionResponse response = topicAdminClient.detachSubscription(request); * } @@ -1208,7 +1093,7 @@ public final DetachSubscriptionResponse detachSubscription(DetachSubscriptionReq * try (TopicAdminClient topicAdminClient = TopicAdminClient.create()) { * DetachSubscriptionRequest request = * DetachSubscriptionRequest.newBuilder() - * .setSubscription(ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString()) + * .setSubscription(SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString()) * .build(); * ApiFuture future = * topicAdminClient.detachSubscriptionCallable().futureCall(request); @@ -1248,37 +1133,6 @@ public final Policy setIamPolicy(SetIamPolicyRequest request) { return setIamPolicyCallable().call(request); } - // AUTO-GENERATED DOCUMENTATION AND METHOD - /** - * Sets the access control policy on the specified resource. Replaces any existing policy. - * - * Can return Public Errors: NOT_FOUND, INVALID_ARGUMENT and PERMISSION_DENIED - * - *
Sample code: - * - *
- * - * @param resource REQUIRED: The resource for which the policy is being specified. See the - * operation documentation for the appropriate value for this field. - * @param policy REQUIRED: The complete policy to be applied to the `resource`. The size of the - * policy is limited to a few 10s of KB. An empty policy is a valid policy but certain Cloud - * Platform services (such as Projects) might reject them. - * @throws com.google.api.gax.rpc.ApiException if the remote call fails - * @deprecated Use {@link #setIamPolicy(SetIamPolicyRequest)} instead. - */ - @Deprecated - public final Policy setIamPolicy(String resource, Policy policy) { - SetIamPolicyRequest request = - SetIamPolicyRequest.newBuilder().setResource(resource).setPolicy(policy).build(); - return setIamPolicy(request); - } - // AUTO-GENERATED DOCUMENTATION AND METHOD. /** * Sets the access control policy on the specified resource. Replacesany existing policy. @@ -1329,31 +1183,6 @@ public final Policy getIamPolicy(GetIamPolicyRequest request) { return getIamPolicyCallable().call(request); } - // AUTO-GENERATED DOCUMENTATION AND METHOD - /** - * Gets the access control policy for a resource. Returns an empty policy if the resource exists - * and does not have a policy set. - * - *- * try (TopicAdminClient topicAdminClient = TopicAdminClient.create()) { - * String formattedResource = ProjectTopicName.format("[PROJECT]", "[TOPIC]"); - * Policy policy = Policy.newBuilder().build(); - * Policy response = topicAdminClient.setIamPolicy(formattedResource, policy); - * } - *
Sample code: - * - *
- * - * @param resource REQUIRED: The resource for which the policy is being requested. See the - * operation documentation for the appropriate value for this field. - * @throws com.google.api.gax.rpc.ApiException if the remote call fails - * @deprecated Use {@link #getIamPolicy(GetIamPolicyRequest)} instead. - */ - @Deprecated - public final Policy getIamPolicy(String resource) { - GetIamPolicyRequest request = GetIamPolicyRequest.newBuilder().setResource(resource).build(); - return getIamPolicy(request); - } - // AUTO-GENERATED DOCUMENTATION AND METHOD. /** * Gets the access control policy for a resource. Returns an empty policyif the resource exists @@ -1407,44 +1236,6 @@ public final TestIamPermissionsResponse testIamPermissions(TestIamPermissionsReq return testIamPermissionsCallable().call(request); } - // AUTO-GENERATED DOCUMENTATION AND METHOD - /** - * Returns permissions that a caller has on the specified resource. If the resource does not - * exist, this will return an empty set of permissions, not a NOT_FOUND error. - * - *- * try (TopicAdminClient topicAdminClient = TopicAdminClient.create()) { - * String formattedResource = ProjectTopicName.format("[PROJECT]", "[TOPIC]"); - * Policy response = topicAdminClient.getIamPolicy(formattedResource); - * } - *
Note: This operation is designed to be used for building permission-aware UIs and - * command-line tools, not for authorization checking. This operation may "fail open" without - * warning. - * - *
Sample code: - * - *
- * - * @param resource REQUIRED: The resource for which the policy detail is being requested. See the - * operation documentation for the appropriate value for this field. - * @param permissions The set of permissions to check for the `resource`. Permissions with - * wildcards (such as '*' or 'storage.*') are not allowed. For more information see - * [IAM Overview](https://cloud.google.com/iam/docs/overview#permissions). - * @throws com.google.api.gax.rpc.ApiException if the remote call fails - * @deprecated Use {@link #testIamPermissions(TestIamPermissionsRequest)} instead. - */ - @Deprecated - public final TestIamPermissionsResponse testIamPermissions( - String resource, List- * try (TopicAdminClient topicAdminClient = TopicAdminClient.create()) { - * String formattedResource = ProjectTopicName.format("[PROJECT]", "[TOPIC]"); - * List<String> permissions = new ArrayList<>(); - * TestIamPermissionsResponse response = topicAdminClient.testIamPermissions(formattedResource, permissions); - * } - *
permissions) { - TestIamPermissionsRequest request = - TestIamPermissionsRequest.newBuilder() - .setResource(resource) - .addAllPermissions(permissions) - .build(); - return testIamPermissions(request); - } - // AUTO-GENERATED DOCUMENTATION AND METHOD. /** * Returns permissions that a caller has on the specified resource. If theresource does not exist, @@ -1507,10 +1298,7 @@ public boolean awaitTermination(long duration, TimeUnit unit) throws Interrupted public static class ListTopicsPagedResponse extends AbstractPagedListResponse< - ListTopicsRequest, - ListTopicsResponse, - Topic, - ListTopicsPage, + ListTopicsRequest, ListTopicsResponse, Topic, ListTopicsPage, ListTopicsFixedSizeCollection> { public static ApiFuture createAsync( @@ -1557,10 +1345,7 @@ public ApiFuture createPageAsync( public static class ListTopicsFixedSizeCollection extends AbstractFixedSizeCollection< - ListTopicsRequest, - ListTopicsResponse, - Topic, - ListTopicsPage, + ListTopicsRequest, ListTopicsResponse, Topic, ListTopicsPage, ListTopicsFixedSizeCollection> { private ListTopicsFixedSizeCollection(List pages, int collectionSize) { @@ -1580,11 +1365,8 @@ protected ListTopicsFixedSizeCollection createCollection( public static class ListTopicSubscriptionsPagedResponse extends AbstractPagedListResponse< - ListTopicSubscriptionsRequest, - ListTopicSubscriptionsResponse, - String, - ListTopicSubscriptionsPage, - ListTopicSubscriptionsFixedSizeCollection> { + ListTopicSubscriptionsRequest, ListTopicSubscriptionsResponse, String, + ListTopicSubscriptionsPage, ListTopicSubscriptionsFixedSizeCollection> { public static ApiFuture createAsync( PageContext context, @@ -1600,24 +1382,11 @@ public static ApiFuture createAsync( private ListTopicSubscriptionsPagedResponse(ListTopicSubscriptionsPage page) { super(page, ListTopicSubscriptionsFixedSizeCollection.createEmptyCollection()); } - - public Iterable iterateAllAsProjectSubscriptionName() { - return Iterables.transform( - iterateAll(), - new Function () { - @Override - public ProjectSubscriptionName apply(String arg0) { - return ProjectSubscriptionName.parse(arg0); - } - }); - } } public static class ListTopicSubscriptionsPage extends AbstractPage< - ListTopicSubscriptionsRequest, - ListTopicSubscriptionsResponse, - String, + ListTopicSubscriptionsRequest, ListTopicSubscriptionsResponse, String, ListTopicSubscriptionsPage> { private ListTopicSubscriptionsPage( @@ -1643,37 +1412,12 @@ public ApiFuture createPageAsync( ApiFuture futureResponse) { return super.createPageAsync(context, futureResponse); } - - public Iterable iterateAllAsProjectSubscriptionName() { - return Iterables.transform( - iterateAll(), - new Function () { - @Override - public ProjectSubscriptionName apply(String arg0) { - return ProjectSubscriptionName.parse(arg0); - } - }); - } - - public Iterable getValuesAsProjectSubscriptionName() { - return Iterables.transform( - getValues(), - new Function () { - @Override - public ProjectSubscriptionName apply(String arg0) { - return ProjectSubscriptionName.parse(arg0); - } - }); - } } public static class ListTopicSubscriptionsFixedSizeCollection extends AbstractFixedSizeCollection< - ListTopicSubscriptionsRequest, - ListTopicSubscriptionsResponse, - String, - ListTopicSubscriptionsPage, - ListTopicSubscriptionsFixedSizeCollection> { + ListTopicSubscriptionsRequest, ListTopicSubscriptionsResponse, String, + ListTopicSubscriptionsPage, ListTopicSubscriptionsFixedSizeCollection> { private ListTopicSubscriptionsFixedSizeCollection( List pages, int collectionSize) { @@ -1689,25 +1433,11 @@ protected ListTopicSubscriptionsFixedSizeCollection createCollection( List pages, int collectionSize) { return new ListTopicSubscriptionsFixedSizeCollection(pages, collectionSize); } - - public Iterable getValuesAsProjectSubscriptionName() { - return Iterables.transform( - getValues(), - new Function () { - @Override - public ProjectSubscriptionName apply(String arg0) { - return ProjectSubscriptionName.parse(arg0); - } - }); - } } public static class ListTopicSnapshotsPagedResponse extends AbstractPagedListResponse< - ListTopicSnapshotsRequest, - ListTopicSnapshotsResponse, - String, - ListTopicSnapshotsPage, + ListTopicSnapshotsRequest, ListTopicSnapshotsResponse, String, ListTopicSnapshotsPage, ListTopicSnapshotsFixedSizeCollection> { public static ApiFuture createAsync( @@ -1757,10 +1487,7 @@ public ApiFuture createPageAsync( public static class ListTopicSnapshotsFixedSizeCollection extends AbstractFixedSizeCollection< - ListTopicSnapshotsRequest, - ListTopicSnapshotsResponse, - String, - ListTopicSnapshotsPage, + ListTopicSnapshotsRequest, ListTopicSnapshotsResponse, String, ListTopicSnapshotsPage, ListTopicSnapshotsFixedSizeCollection> { private ListTopicSnapshotsFixedSizeCollection( diff --git a/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/TopicAdminSettings.java b/owl-bot-staging/v1/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/TopicAdminSettings.java similarity index 96% rename from google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/TopicAdminSettings.java rename to owl-bot-staging/v1/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/TopicAdminSettings.java index 41ebfd68d..a27bc40ae 100644 --- a/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/TopicAdminSettings.java +++ b/owl-bot-staging/v1/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/TopicAdminSettings.java @@ -30,6 +30,7 @@ import com.google.api.gax.rpc.ClientContext; import com.google.api.gax.rpc.ClientSettings; import com.google.api.gax.rpc.PagedCallSettings; +import com.google.api.gax.rpc.StubSettings; import com.google.api.gax.rpc.TransportChannelProvider; import com.google.api.gax.rpc.UnaryCallSettings; import com.google.cloud.pubsub.v1.stub.PublisherStubSettings; @@ -64,9 +65,9 @@ * The default instance has everything set to sensible defaults: * *
- *
* *- The default service address (pubsub.googleapis.com) and default port (443) are used. - *
- Credentials are acquired automatically through Application Default Credentials. - *
- Retries are configured for idempotent methods but not for non-idempotent methods. + *
- The default service address (pubsub.googleapis.com) and default port (443) are used. + *
- Credentials are acquired automatically through Application Default Credentials. + *
- Retries are configured for idempotent methods but not for non-idempotent methods. *
The builder of this class is recursive, so contained classes are themselves builders. When @@ -119,8 +120,7 @@ public UnaryCallSettings
getTopicSettings() { /** Returns the object with the settings used for calls to listTopicSubscriptions. */ public PagedCallSettings< - ListTopicSubscriptionsRequest, - ListTopicSubscriptionsResponse, + ListTopicSubscriptionsRequest, ListTopicSubscriptionsResponse, ListTopicSubscriptionsPagedResponse> listTopicSubscriptionsSettings() { return ((PublisherStubSettings) getStubSettings()).listTopicSubscriptionsSettings(); @@ -284,8 +284,7 @@ public UnaryCallSettings.Builder getTopicSettings() { /** Returns the builder for the settings used for calls to listTopicSubscriptions. */ public PagedCallSettings.Builder< - ListTopicSubscriptionsRequest, - ListTopicSubscriptionsResponse, + ListTopicSubscriptionsRequest, ListTopicSubscriptionsResponse, ListTopicSubscriptionsPagedResponse> listTopicSubscriptionsSettings() { return getStubSettingsBuilder().listTopicSubscriptionsSettings(); diff --git a/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/gapic_metadata.json b/owl-bot-staging/v1/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/gapic_metadata.json similarity index 100% rename from google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/gapic_metadata.json rename to owl-bot-staging/v1/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/gapic_metadata.json diff --git a/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/package-info.java b/owl-bot-staging/v1/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/package-info.java similarity index 96% rename from google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/package-info.java rename to owl-bot-staging/v1/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/package-info.java index 820341320..128d54247 100644 --- a/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/package-info.java +++ b/owl-bot-staging/v1/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/package-info.java @@ -43,7 +43,7 @@ * * {@code * try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) { - * ProjectSubscriptionName name = ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]"); + * SubscriptionName name = SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]"); * TopicName topic = TopicName.ofProjectTopicName("[PROJECT]", "[TOPIC]"); * PushConfig pushConfig = PushConfig.newBuilder().build(); * int ackDeadlineSeconds = 2135351438; diff --git a/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/GrpcPublisherCallableFactory.java b/owl-bot-staging/v1/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/GrpcPublisherCallableFactory.java similarity index 100% rename from google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/GrpcPublisherCallableFactory.java rename to owl-bot-staging/v1/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/GrpcPublisherCallableFactory.java diff --git a/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/GrpcPublisherStub.java b/owl-bot-staging/v1/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/GrpcPublisherStub.java similarity index 99% rename from google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/GrpcPublisherStub.java rename to owl-bot-staging/v1/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/GrpcPublisherStub.java index 5ccb0793e..e7f1114ed 100644 --- a/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/GrpcPublisherStub.java +++ b/owl-bot-staging/v1/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/GrpcPublisherStub.java @@ -51,6 +51,7 @@ import io.grpc.MethodDescriptor; import io.grpc.protobuf.ProtoUtils; import java.io.IOException; +import java.util.Map; import java.util.concurrent.TimeUnit; import javax.annotation.Generated; @@ -369,7 +370,7 @@ protected GrpcPublisherStub( callableFactory.createUnaryCallable( updateTopicTransportSettings, settings.updateTopicSettings(), clientContext); this.publishCallable = - callableFactory.createUnaryCallable( + callableFactory.createBatchingCallable( publishTransportSettings, settings.publishSettings(), clientContext); this.getTopicCallable = callableFactory.createUnaryCallable( diff --git a/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/GrpcSchemaServiceCallableFactory.java b/owl-bot-staging/v1/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/GrpcSchemaServiceCallableFactory.java similarity index 100% rename from google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/GrpcSchemaServiceCallableFactory.java rename to owl-bot-staging/v1/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/GrpcSchemaServiceCallableFactory.java diff --git a/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/GrpcSchemaServiceStub.java b/owl-bot-staging/v1/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/GrpcSchemaServiceStub.java similarity index 99% rename from google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/GrpcSchemaServiceStub.java rename to owl-bot-staging/v1/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/GrpcSchemaServiceStub.java index e5cd65fb6..2ec4a2731 100644 --- a/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/GrpcSchemaServiceStub.java +++ b/owl-bot-staging/v1/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/GrpcSchemaServiceStub.java @@ -45,6 +45,7 @@ import io.grpc.MethodDescriptor; import io.grpc.protobuf.ProtoUtils; import java.io.IOException; +import java.util.Map; import java.util.concurrent.TimeUnit; import javax.annotation.Generated; diff --git a/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/GrpcSubscriberCallableFactory.java b/owl-bot-staging/v1/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/GrpcSubscriberCallableFactory.java similarity index 100% rename from google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/GrpcSubscriberCallableFactory.java rename to owl-bot-staging/v1/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/GrpcSubscriberCallableFactory.java diff --git a/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/GrpcSubscriberStub.java b/owl-bot-staging/v1/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/GrpcSubscriberStub.java similarity index 99% rename from google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/GrpcSubscriberStub.java rename to owl-bot-staging/v1/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/GrpcSubscriberStub.java index 523c0376a..f4da74706 100644 --- a/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/GrpcSubscriberStub.java +++ b/owl-bot-staging/v1/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/GrpcSubscriberStub.java @@ -59,6 +59,7 @@ import io.grpc.MethodDescriptor; import io.grpc.protobuf.ProtoUtils; import java.io.IOException; +import java.util.Map; import java.util.concurrent.TimeUnit; import javax.annotation.Generated; diff --git a/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/PublisherStub.java b/owl-bot-staging/v1/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/PublisherStub.java similarity index 100% rename from google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/PublisherStub.java rename to owl-bot-staging/v1/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/PublisherStub.java diff --git a/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/PublisherStubSettings.java b/owl-bot-staging/v1/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/PublisherStubSettings.java similarity index 97% rename from google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/PublisherStubSettings.java rename to owl-bot-staging/v1/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/PublisherStubSettings.java index 166775ec3..0de55871f 100644 --- a/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/PublisherStubSettings.java +++ b/owl-bot-staging/v1/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/PublisherStubSettings.java @@ -88,9 +88,9 @@ *The default instance has everything set to sensible defaults: * *
- *
* *- The default service address (pubsub.googleapis.com) and default port (443) are used. - *
- Credentials are acquired automatically through Application Default Credentials. - *
- Retries are configured for idempotent methods but not for non-idempotent methods. + *
- The default service address (pubsub.googleapis.com) and default port (443) are used. + *
- Credentials are acquired automatically through Application Default Credentials. + *
- Retries are configured for idempotent methods but not for non-idempotent methods. *
The builder of this class is recursive, so contained classes are themselves builders. When @@ -128,8 +128,7 @@ public class PublisherStubSettings extends StubSettings
{ private final PagedCallSettings listTopicsSettings; private final PagedCallSettings< - ListTopicSubscriptionsRequest, - ListTopicSubscriptionsResponse, + ListTopicSubscriptionsRequest, ListTopicSubscriptionsResponse, ListTopicSubscriptionsPagedResponse> listTopicSubscriptionsSettings; private final PagedCallSettings< @@ -278,13 +277,11 @@ public ApiFuture getFuturePagedResponse( }; private static final PagedListResponseFactory< - ListTopicSubscriptionsRequest, - ListTopicSubscriptionsResponse, + ListTopicSubscriptionsRequest, ListTopicSubscriptionsResponse, ListTopicSubscriptionsPagedResponse> LIST_TOPIC_SUBSCRIPTIONS_PAGE_STR_FACT = new PagedListResponseFactory< - ListTopicSubscriptionsRequest, - ListTopicSubscriptionsResponse, + ListTopicSubscriptionsRequest, ListTopicSubscriptionsResponse, ListTopicSubscriptionsPagedResponse>() { @Override public ApiFuture getFuturePagedResponse( @@ -305,8 +302,7 @@ public ApiFuture getFuturePagedResponse( ListTopicSnapshotsRequest, ListTopicSnapshotsResponse, ListTopicSnapshotsPagedResponse> LIST_TOPIC_SNAPSHOTS_PAGE_STR_FACT = new PagedListResponseFactory< - ListTopicSnapshotsRequest, - ListTopicSnapshotsResponse, + ListTopicSnapshotsRequest, ListTopicSnapshotsResponse, ListTopicSnapshotsPagedResponse>() { @Override public ApiFuture getFuturePagedResponse( @@ -415,8 +411,7 @@ public UnaryCallSettings getTopicSettings() { /** Returns the object with the settings used for calls to listTopicSubscriptions. */ public PagedCallSettings< - ListTopicSubscriptionsRequest, - ListTopicSubscriptionsResponse, + ListTopicSubscriptionsRequest, ListTopicSubscriptionsResponse, ListTopicSubscriptionsPagedResponse> listTopicSubscriptionsSettings() { return listTopicSubscriptionsSettings; @@ -556,8 +551,7 @@ public static class Builder extends StubSettings.Builder listTopicsSettings; private final PagedCallSettings.Builder< - ListTopicSubscriptionsRequest, - ListTopicSubscriptionsResponse, + ListTopicSubscriptionsRequest, ListTopicSubscriptionsResponse, ListTopicSubscriptionsPagedResponse> listTopicSubscriptionsSettings; private final PagedCallSettings.Builder< @@ -844,8 +838,7 @@ public UnaryCallSettings.Builder getTopicSettings() { /** Returns the builder for the settings used for calls to listTopicSubscriptions. */ public PagedCallSettings.Builder< - ListTopicSubscriptionsRequest, - ListTopicSubscriptionsResponse, + ListTopicSubscriptionsRequest, ListTopicSubscriptionsResponse, ListTopicSubscriptionsPagedResponse> listTopicSubscriptionsSettings() { return listTopicSubscriptionsSettings; diff --git a/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/SchemaServiceStub.java b/owl-bot-staging/v1/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/SchemaServiceStub.java similarity index 100% rename from google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/SchemaServiceStub.java rename to owl-bot-staging/v1/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/SchemaServiceStub.java diff --git a/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/SchemaServiceStubSettings.java b/owl-bot-staging/v1/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/SchemaServiceStubSettings.java similarity index 98% rename from google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/SchemaServiceStubSettings.java rename to owl-bot-staging/v1/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/SchemaServiceStubSettings.java index fb8a87653..ab480e74f 100644 --- a/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/SchemaServiceStubSettings.java +++ b/owl-bot-staging/v1/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/SchemaServiceStubSettings.java @@ -71,9 +71,9 @@ * The default instance has everything set to sensible defaults: * *
- *
* *- The default service address (pubsub.googleapis.com) and default port (443) are used. - *
- Credentials are acquired automatically through Application Default Credentials. - *
- Retries are configured for idempotent methods but not for non-idempotent methods. + *
- The default service address (pubsub.googleapis.com) and default port (443) are used. + *
- Credentials are acquired automatically through Application Default Credentials. + *
- Retries are configured for idempotent methods but not for non-idempotent methods. *
The builder of this class is recursive, so contained classes are themselves builders. When diff --git a/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/SubscriberStub.java b/owl-bot-staging/v1/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/SubscriberStub.java similarity index 100% rename from google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/SubscriberStub.java rename to owl-bot-staging/v1/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/SubscriberStub.java diff --git a/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/SubscriberStubSettings.java b/owl-bot-staging/v1/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/SubscriberStubSettings.java similarity index 98% rename from google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/SubscriberStubSettings.java rename to owl-bot-staging/v1/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/SubscriberStubSettings.java index 32733fbf9..c42ca6381 100644 --- a/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/SubscriberStubSettings.java +++ b/owl-bot-staging/v1/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/SubscriberStubSettings.java @@ -86,9 +86,9 @@ *
The default instance has everything set to sensible defaults: * *
- *
* *- The default service address (pubsub.googleapis.com) and default port (443) are used. - *
- Credentials are acquired automatically through Application Default Credentials. - *
- Retries are configured for idempotent methods but not for non-idempotent methods. + *
- The default service address (pubsub.googleapis.com) and default port (443) are used. + *
- Credentials are acquired automatically through Application Default Credentials. + *
- Retries are configured for idempotent methods but not for non-idempotent methods. *
The builder of this class is recursive, so contained classes are themselves builders. When @@ -227,8 +227,7 @@ public Iterable
extractResources(ListSnapshotsResponse payload) { ListSubscriptionsRequest, ListSubscriptionsResponse, ListSubscriptionsPagedResponse> LIST_SUBSCRIPTIONS_PAGE_STR_FACT = new PagedListResponseFactory< - ListSubscriptionsRequest, - ListSubscriptionsResponse, + ListSubscriptionsRequest, ListSubscriptionsResponse, ListSubscriptionsPagedResponse>() { @Override public ApiFuture getFuturePagedResponse( @@ -402,7 +401,8 @@ public static GoogleCredentialsProvider.Builder defaultCredentialsProviderBuilde /** Returns a builder for the default ChannelProvider for this service. */ public static InstantiatingGrpcChannelProvider.Builder defaultGrpcTransportProviderBuilder() { - return InstantiatingGrpcChannelProvider.newBuilder().setMaxInboundMessageSize(20 << 20); + return InstantiatingGrpcChannelProvider.newBuilder() + .setMaxInboundMessageSize(Integer.MAX_VALUE); } public static TransportChannelProvider defaultTransportChannelProvider() { diff --git a/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/MockIAMPolicy.java b/owl-bot-staging/v1/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/MockIAMPolicy.java similarity index 100% rename from google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/MockIAMPolicy.java rename to owl-bot-staging/v1/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/MockIAMPolicy.java diff --git a/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/MockIAMPolicyImpl.java b/owl-bot-staging/v1/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/MockIAMPolicyImpl.java similarity index 100% rename from google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/MockIAMPolicyImpl.java rename to owl-bot-staging/v1/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/MockIAMPolicyImpl.java diff --git a/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/MockPublisher.java b/owl-bot-staging/v1/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/MockPublisher.java similarity index 100% rename from google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/MockPublisher.java rename to owl-bot-staging/v1/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/MockPublisher.java diff --git a/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/MockPublisherImpl.java b/owl-bot-staging/v1/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/MockPublisherImpl.java similarity index 100% rename from google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/MockPublisherImpl.java rename to owl-bot-staging/v1/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/MockPublisherImpl.java diff --git a/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/MockSchemaService.java b/owl-bot-staging/v1/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/MockSchemaService.java similarity index 100% rename from google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/MockSchemaService.java rename to owl-bot-staging/v1/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/MockSchemaService.java diff --git a/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/MockSchemaServiceImpl.java b/owl-bot-staging/v1/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/MockSchemaServiceImpl.java similarity index 100% rename from google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/MockSchemaServiceImpl.java rename to owl-bot-staging/v1/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/MockSchemaServiceImpl.java diff --git a/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/MockSubscriber.java b/owl-bot-staging/v1/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/MockSubscriber.java similarity index 100% rename from google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/MockSubscriber.java rename to owl-bot-staging/v1/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/MockSubscriber.java diff --git a/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/MockSubscriberImpl.java b/owl-bot-staging/v1/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/MockSubscriberImpl.java similarity index 100% rename from google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/MockSubscriberImpl.java rename to owl-bot-staging/v1/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/MockSubscriberImpl.java diff --git a/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/SchemaServiceClientTest.java b/owl-bot-staging/v1/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/SchemaServiceClientTest.java similarity index 100% rename from google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/SchemaServiceClientTest.java rename to owl-bot-staging/v1/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/SchemaServiceClientTest.java diff --git a/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/SubscriptionAdminClientTest.java b/owl-bot-staging/v1/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/SubscriptionAdminClientTest.java similarity index 93% rename from google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/SubscriptionAdminClientTest.java rename to owl-bot-staging/v1/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/SubscriptionAdminClientTest.java index 00753a6fb..9d53a7554 100644 --- a/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/SubscriptionAdminClientTest.java +++ b/owl-bot-staging/v1/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/SubscriptionAdminClientTest.java @@ -59,8 +59,6 @@ import com.google.pubsub.v1.ModifyAckDeadlineRequest; import com.google.pubsub.v1.ModifyPushConfigRequest; import com.google.pubsub.v1.ProjectName; -import com.google.pubsub.v1.ProjectSnapshotName; -import com.google.pubsub.v1.ProjectSubscriptionName; import com.google.pubsub.v1.PullRequest; import com.google.pubsub.v1.PullResponse; import com.google.pubsub.v1.PushConfig; @@ -69,9 +67,11 @@ import com.google.pubsub.v1.SeekRequest; import com.google.pubsub.v1.SeekResponse; import com.google.pubsub.v1.Snapshot; +import com.google.pubsub.v1.SnapshotName; import com.google.pubsub.v1.StreamingPullRequest; import com.google.pubsub.v1.StreamingPullResponse; import com.google.pubsub.v1.Subscription; +import com.google.pubsub.v1.SubscriptionName; import com.google.pubsub.v1.TopicName; import com.google.pubsub.v1.UpdateSnapshotRequest; import com.google.pubsub.v1.UpdateSubscriptionRequest; @@ -136,7 +136,7 @@ public void tearDown() throws Exception { public void createSubscriptionTest() throws Exception { Subscription expectedResponse = Subscription.newBuilder() - .setName(ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString()) + .setName(SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString()) .setTopic(TopicName.ofProjectTopicName("[PROJECT]", "[TOPIC]").toString()) .setPushConfig(PushConfig.newBuilder().build()) .setAckDeadlineSeconds(2135351438) @@ -153,7 +153,7 @@ public void createSubscriptionTest() throws Exception { .build(); mockSubscriber.addResponse(expectedResponse); - ProjectSubscriptionName name = ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]"); + SubscriptionName name = SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]"); TopicName topic = TopicName.ofProjectTopicName("[PROJECT]", "[TOPIC]"); PushConfig pushConfig = PushConfig.newBuilder().build(); int ackDeadlineSeconds = 2135351438; @@ -182,7 +182,7 @@ public void createSubscriptionExceptionTest() throws Exception { mockSubscriber.addException(exception); try { - ProjectSubscriptionName name = ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]"); + SubscriptionName name = SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]"); TopicName topic = TopicName.ofProjectTopicName("[PROJECT]", "[TOPIC]"); PushConfig pushConfig = PushConfig.newBuilder().build(); int ackDeadlineSeconds = 2135351438; @@ -197,7 +197,7 @@ public void createSubscriptionExceptionTest() throws Exception { public void createSubscriptionTest2() throws Exception { Subscription expectedResponse = Subscription.newBuilder() - .setName(ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString()) + .setName(SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString()) .setTopic(TopicName.ofProjectTopicName("[PROJECT]", "[TOPIC]").toString()) .setPushConfig(PushConfig.newBuilder().build()) .setAckDeadlineSeconds(2135351438) @@ -214,7 +214,7 @@ public void createSubscriptionTest2() throws Exception { .build(); mockSubscriber.addResponse(expectedResponse); - ProjectSubscriptionName name = ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]"); + SubscriptionName name = SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]"); String topic = "topic110546223"; PushConfig pushConfig = PushConfig.newBuilder().build(); int ackDeadlineSeconds = 2135351438; @@ -243,7 +243,7 @@ public void createSubscriptionExceptionTest2() throws Exception { mockSubscriber.addException(exception); try { - ProjectSubscriptionName name = ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]"); + SubscriptionName name = SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]"); String topic = "topic110546223"; PushConfig pushConfig = PushConfig.newBuilder().build(); int ackDeadlineSeconds = 2135351438; @@ -258,7 +258,7 @@ public void createSubscriptionExceptionTest2() throws Exception { public void createSubscriptionTest3() throws Exception { Subscription expectedResponse = Subscription.newBuilder() - .setName(ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString()) + .setName(SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString()) .setTopic(TopicName.ofProjectTopicName("[PROJECT]", "[TOPIC]").toString()) .setPushConfig(PushConfig.newBuilder().build()) .setAckDeadlineSeconds(2135351438) @@ -319,7 +319,7 @@ public void createSubscriptionExceptionTest3() throws Exception { public void createSubscriptionTest4() throws Exception { Subscription expectedResponse = Subscription.newBuilder() - .setName(ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString()) + .setName(SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString()) .setTopic(TopicName.ofProjectTopicName("[PROJECT]", "[TOPIC]").toString()) .setPushConfig(PushConfig.newBuilder().build()) .setAckDeadlineSeconds(2135351438) @@ -380,7 +380,7 @@ public void createSubscriptionExceptionTest4() throws Exception { public void getSubscriptionTest() throws Exception { Subscription expectedResponse = Subscription.newBuilder() - .setName(ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString()) + .setName(SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString()) .setTopic(TopicName.ofProjectTopicName("[PROJECT]", "[TOPIC]").toString()) .setPushConfig(PushConfig.newBuilder().build()) .setAckDeadlineSeconds(2135351438) @@ -397,8 +397,7 @@ public void getSubscriptionTest() throws Exception { .build(); mockSubscriber.addResponse(expectedResponse); - ProjectSubscriptionName subscription = - ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]"); + SubscriptionName subscription = SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]"); Subscription actualResponse = client.getSubscription(subscription); Assert.assertEquals(expectedResponse, actualResponse); @@ -420,8 +419,7 @@ public void getSubscriptionExceptionTest() throws Exception { mockSubscriber.addException(exception); try { - ProjectSubscriptionName subscription = - ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]"); + SubscriptionName subscription = SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]"); client.getSubscription(subscription); Assert.fail("No exception raised"); } catch (InvalidArgumentException e) { @@ -433,7 +431,7 @@ public void getSubscriptionExceptionTest() throws Exception { public void getSubscriptionTest2() throws Exception { Subscription expectedResponse = Subscription.newBuilder() - .setName(ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString()) + .setName(SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString()) .setTopic(TopicName.ofProjectTopicName("[PROJECT]", "[TOPIC]").toString()) .setPushConfig(PushConfig.newBuilder().build()) .setAckDeadlineSeconds(2135351438) @@ -484,7 +482,7 @@ public void getSubscriptionExceptionTest2() throws Exception { public void updateSubscriptionTest() throws Exception { Subscription expectedResponse = Subscription.newBuilder() - .setName(ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString()) + .setName(SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString()) .setTopic(TopicName.ofProjectTopicName("[PROJECT]", "[TOPIC]").toString()) .setPushConfig(PushConfig.newBuilder().build()) .setAckDeadlineSeconds(2135351438) @@ -633,8 +631,7 @@ public void deleteSubscriptionTest() throws Exception { Empty expectedResponse = Empty.newBuilder().build(); mockSubscriber.addResponse(expectedResponse); - ProjectSubscriptionName subscription = - ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]"); + SubscriptionName subscription = SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]"); client.deleteSubscription(subscription); @@ -655,8 +652,7 @@ public void deleteSubscriptionExceptionTest() throws Exception { mockSubscriber.addException(exception); try { - ProjectSubscriptionName subscription = - ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]"); + SubscriptionName subscription = SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]"); client.deleteSubscription(subscription); Assert.fail("No exception raised"); } catch (InvalidArgumentException e) { @@ -703,8 +699,7 @@ public void modifyAckDeadlineTest() throws Exception { Empty expectedResponse = Empty.newBuilder().build(); mockSubscriber.addResponse(expectedResponse); - ProjectSubscriptionName subscription = - ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]"); + SubscriptionName subscription = SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]"); List ackIds = new ArrayList<>(); int ackDeadlineSeconds = 2135351438; @@ -729,8 +724,7 @@ public void modifyAckDeadlineExceptionTest() throws Exception { mockSubscriber.addException(exception); try { - ProjectSubscriptionName subscription = - ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]"); + SubscriptionName subscription = SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]"); List ackIds = new ArrayList<>(); int ackDeadlineSeconds = 2135351438; client.modifyAckDeadline(subscription, ackIds, ackDeadlineSeconds); @@ -785,8 +779,7 @@ public void acknowledgeTest() throws Exception { Empty expectedResponse = Empty.newBuilder().build(); mockSubscriber.addResponse(expectedResponse); - ProjectSubscriptionName subscription = - ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]"); + SubscriptionName subscription = SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]"); List ackIds = new ArrayList<>(); client.acknowledge(subscription, ackIds); @@ -809,8 +802,7 @@ public void acknowledgeExceptionTest() throws Exception { mockSubscriber.addException(exception); try { - ProjectSubscriptionName subscription = - ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]"); + SubscriptionName subscription = SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]"); List ackIds = new ArrayList<>(); client.acknowledge(subscription, ackIds); Assert.fail("No exception raised"); @@ -862,8 +854,7 @@ public void pullTest() throws Exception { PullResponse.newBuilder().addAllReceivedMessages(new ArrayList ()).build(); mockSubscriber.addResponse(expectedResponse); - ProjectSubscriptionName subscription = - ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]"); + SubscriptionName subscription = SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]"); int maxMessages = 496131527; PullResponse actualResponse = client.pull(subscription, maxMessages); @@ -887,8 +878,7 @@ public void pullExceptionTest() throws Exception { mockSubscriber.addException(exception); try { - ProjectSubscriptionName subscription = - ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]"); + SubscriptionName subscription = SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]"); int maxMessages = 496131527; client.pull(subscription, maxMessages); Assert.fail("No exception raised"); @@ -942,8 +932,7 @@ public void pullTest3() throws Exception { PullResponse.newBuilder().addAllReceivedMessages(new ArrayList ()).build(); mockSubscriber.addResponse(expectedResponse); - ProjectSubscriptionName subscription = - ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]"); + SubscriptionName subscription = SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]"); boolean returnImmediately = true; int maxMessages = 496131527; @@ -969,8 +958,7 @@ public void pullExceptionTest3() throws Exception { mockSubscriber.addException(exception); try { - ProjectSubscriptionName subscription = - ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]"); + SubscriptionName subscription = SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]"); boolean returnImmediately = true; int maxMessages = 496131527; client.pull(subscription, returnImmediately, maxMessages); @@ -1033,7 +1021,7 @@ public void streamingPullTest() throws Exception { mockSubscriber.addResponse(expectedResponse); StreamingPullRequest request = StreamingPullRequest.newBuilder() - .setSubscription(ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString()) + .setSubscription(SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString()) .addAllAckIds(new ArrayList ()) .addAllModifyDeadlineSeconds(new ArrayList ()) .addAllModifyDeadlineAckIds(new ArrayList ()) @@ -1064,7 +1052,7 @@ public void streamingPullExceptionTest() throws Exception { mockSubscriber.addException(exception); StreamingPullRequest request = StreamingPullRequest.newBuilder() - .setSubscription(ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString()) + .setSubscription(SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString()) .addAllAckIds(new ArrayList ()) .addAllModifyDeadlineSeconds(new ArrayList ()) .addAllModifyDeadlineAckIds(new ArrayList ()) @@ -1098,8 +1086,7 @@ public void modifyPushConfigTest() throws Exception { Empty expectedResponse = Empty.newBuilder().build(); mockSubscriber.addResponse(expectedResponse); - ProjectSubscriptionName subscription = - ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]"); + SubscriptionName subscription = SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]"); PushConfig pushConfig = PushConfig.newBuilder().build(); client.modifyPushConfig(subscription, pushConfig); @@ -1122,8 +1109,7 @@ public void modifyPushConfigExceptionTest() throws Exception { mockSubscriber.addException(exception); try { - ProjectSubscriptionName subscription = - ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]"); + SubscriptionName subscription = SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]"); PushConfig pushConfig = PushConfig.newBuilder().build(); client.modifyPushConfig(subscription, pushConfig); Assert.fail("No exception raised"); @@ -1173,14 +1159,14 @@ public void modifyPushConfigExceptionTest2() throws Exception { public void getSnapshotTest() throws Exception { Snapshot expectedResponse = Snapshot.newBuilder() - .setName(ProjectSnapshotName.of("[PROJECT]", "[SNAPSHOT]").toString()) + .setName(SnapshotName.of("[PROJECT]", "[SNAPSHOT]").toString()) .setTopic(TopicName.ofProjectTopicName("[PROJECT]", "[TOPIC]").toString()) .setExpireTime(Timestamp.newBuilder().build()) .putAllLabels(new HashMap ()) .build(); mockSubscriber.addResponse(expectedResponse); - ProjectSnapshotName snapshot = ProjectSnapshotName.of("[PROJECT]", "[SNAPSHOT]"); + SnapshotName snapshot = SnapshotName.of("[PROJECT]", "[SNAPSHOT]"); Snapshot actualResponse = client.getSnapshot(snapshot); Assert.assertEquals(expectedResponse, actualResponse); @@ -1202,7 +1188,7 @@ public void getSnapshotExceptionTest() throws Exception { mockSubscriber.addException(exception); try { - ProjectSnapshotName snapshot = ProjectSnapshotName.of("[PROJECT]", "[SNAPSHOT]"); + SnapshotName snapshot = SnapshotName.of("[PROJECT]", "[SNAPSHOT]"); client.getSnapshot(snapshot); Assert.fail("No exception raised"); } catch (InvalidArgumentException e) { @@ -1214,7 +1200,7 @@ public void getSnapshotExceptionTest() throws Exception { public void getSnapshotTest2() throws Exception { Snapshot expectedResponse = Snapshot.newBuilder() - .setName(ProjectSnapshotName.of("[PROJECT]", "[SNAPSHOT]").toString()) + .setName(SnapshotName.of("[PROJECT]", "[SNAPSHOT]").toString()) .setTopic(TopicName.ofProjectTopicName("[PROJECT]", "[TOPIC]").toString()) .setExpireTime(Timestamp.newBuilder().build()) .putAllLabels(new HashMap ()) @@ -1343,16 +1329,15 @@ public void listSnapshotsExceptionTest2() throws Exception { public void createSnapshotTest() throws Exception { Snapshot expectedResponse = Snapshot.newBuilder() - .setName(ProjectSnapshotName.of("[PROJECT]", "[SNAPSHOT]").toString()) + .setName(SnapshotName.of("[PROJECT]", "[SNAPSHOT]").toString()) .setTopic(TopicName.ofProjectTopicName("[PROJECT]", "[TOPIC]").toString()) .setExpireTime(Timestamp.newBuilder().build()) .putAllLabels(new HashMap ()) .build(); mockSubscriber.addResponse(expectedResponse); - ProjectSnapshotName name = ProjectSnapshotName.of("[PROJECT]", "[SNAPSHOT]"); - ProjectSubscriptionName subscription = - ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]"); + SnapshotName name = SnapshotName.of("[PROJECT]", "[SNAPSHOT]"); + SubscriptionName subscription = SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]"); Snapshot actualResponse = client.createSnapshot(name, subscription); Assert.assertEquals(expectedResponse, actualResponse); @@ -1375,9 +1360,8 @@ public void createSnapshotExceptionTest() throws Exception { mockSubscriber.addException(exception); try { - ProjectSnapshotName name = ProjectSnapshotName.of("[PROJECT]", "[SNAPSHOT]"); - ProjectSubscriptionName subscription = - ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]"); + SnapshotName name = SnapshotName.of("[PROJECT]", "[SNAPSHOT]"); + SubscriptionName subscription = SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]"); client.createSnapshot(name, subscription); Assert.fail("No exception raised"); } catch (InvalidArgumentException e) { @@ -1389,14 +1373,14 @@ public void createSnapshotExceptionTest() throws Exception { public void createSnapshotTest2() throws Exception { Snapshot expectedResponse = Snapshot.newBuilder() - .setName(ProjectSnapshotName.of("[PROJECT]", "[SNAPSHOT]").toString()) + .setName(SnapshotName.of("[PROJECT]", "[SNAPSHOT]").toString()) .setTopic(TopicName.ofProjectTopicName("[PROJECT]", "[TOPIC]").toString()) .setExpireTime(Timestamp.newBuilder().build()) .putAllLabels(new HashMap ()) .build(); mockSubscriber.addResponse(expectedResponse); - ProjectSnapshotName name = ProjectSnapshotName.of("[PROJECT]", "[SNAPSHOT]"); + SnapshotName name = SnapshotName.of("[PROJECT]", "[SNAPSHOT]"); String subscription = "subscription341203229"; Snapshot actualResponse = client.createSnapshot(name, subscription); @@ -1420,7 +1404,7 @@ public void createSnapshotExceptionTest2() throws Exception { mockSubscriber.addException(exception); try { - ProjectSnapshotName name = ProjectSnapshotName.of("[PROJECT]", "[SNAPSHOT]"); + SnapshotName name = SnapshotName.of("[PROJECT]", "[SNAPSHOT]"); String subscription = "subscription341203229"; client.createSnapshot(name, subscription); Assert.fail("No exception raised"); @@ -1433,7 +1417,7 @@ public void createSnapshotExceptionTest2() throws Exception { public void createSnapshotTest3() throws Exception { Snapshot expectedResponse = Snapshot.newBuilder() - .setName(ProjectSnapshotName.of("[PROJECT]", "[SNAPSHOT]").toString()) + .setName(SnapshotName.of("[PROJECT]", "[SNAPSHOT]").toString()) .setTopic(TopicName.ofProjectTopicName("[PROJECT]", "[TOPIC]").toString()) .setExpireTime(Timestamp.newBuilder().build()) .putAllLabels(new HashMap ()) @@ -1441,8 +1425,7 @@ public void createSnapshotTest3() throws Exception { mockSubscriber.addResponse(expectedResponse); String name = "name3373707"; - ProjectSubscriptionName subscription = - ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]"); + SubscriptionName subscription = SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]"); Snapshot actualResponse = client.createSnapshot(name, subscription); Assert.assertEquals(expectedResponse, actualResponse); @@ -1466,8 +1449,7 @@ public void createSnapshotExceptionTest3() throws Exception { try { String name = "name3373707"; - ProjectSubscriptionName subscription = - ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]"); + SubscriptionName subscription = SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]"); client.createSnapshot(name, subscription); Assert.fail("No exception raised"); } catch (InvalidArgumentException e) { @@ -1479,7 +1461,7 @@ public void createSnapshotExceptionTest3() throws Exception { public void createSnapshotTest4() throws Exception { Snapshot expectedResponse = Snapshot.newBuilder() - .setName(ProjectSnapshotName.of("[PROJECT]", "[SNAPSHOT]").toString()) + .setName(SnapshotName.of("[PROJECT]", "[SNAPSHOT]").toString()) .setTopic(TopicName.ofProjectTopicName("[PROJECT]", "[TOPIC]").toString()) .setExpireTime(Timestamp.newBuilder().build()) .putAllLabels(new HashMap ()) @@ -1523,7 +1505,7 @@ public void createSnapshotExceptionTest4() throws Exception { public void updateSnapshotTest() throws Exception { Snapshot expectedResponse = Snapshot.newBuilder() - .setName(ProjectSnapshotName.of("[PROJECT]", "[SNAPSHOT]").toString()) + .setName(SnapshotName.of("[PROJECT]", "[SNAPSHOT]").toString()) .setTopic(TopicName.ofProjectTopicName("[PROJECT]", "[TOPIC]").toString()) .setExpireTime(Timestamp.newBuilder().build()) .putAllLabels(new HashMap ()) @@ -1574,7 +1556,7 @@ public void deleteSnapshotTest() throws Exception { Empty expectedResponse = Empty.newBuilder().build(); mockSubscriber.addResponse(expectedResponse); - ProjectSnapshotName snapshot = ProjectSnapshotName.of("[PROJECT]", "[SNAPSHOT]"); + SnapshotName snapshot = SnapshotName.of("[PROJECT]", "[SNAPSHOT]"); client.deleteSnapshot(snapshot); @@ -1595,7 +1577,7 @@ public void deleteSnapshotExceptionTest() throws Exception { mockSubscriber.addException(exception); try { - ProjectSnapshotName snapshot = ProjectSnapshotName.of("[PROJECT]", "[SNAPSHOT]"); + SnapshotName snapshot = SnapshotName.of("[PROJECT]", "[SNAPSHOT]"); client.deleteSnapshot(snapshot); Assert.fail("No exception raised"); } catch (InvalidArgumentException e) { @@ -1644,7 +1626,7 @@ public void seekTest() throws Exception { SeekRequest request = SeekRequest.newBuilder() - .setSubscription(ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString()) + .setSubscription(SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString()) .build(); SeekResponse actualResponse = client.seek(request); @@ -1671,7 +1653,7 @@ public void seekExceptionTest() throws Exception { try { SeekRequest request = SeekRequest.newBuilder() - .setSubscription(ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString()) + .setSubscription(SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString()) .build(); client.seek(request); Assert.fail("No exception raised"); diff --git a/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/TopicAdminClientTest.java b/owl-bot-staging/v1/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/TopicAdminClientTest.java similarity index 99% rename from google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/TopicAdminClientTest.java rename to owl-bot-staging/v1/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/TopicAdminClientTest.java index 4cf5a7502..02d6a5585 100644 --- a/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/TopicAdminClientTest.java +++ b/owl-bot-staging/v1/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/TopicAdminClientTest.java @@ -52,11 +52,11 @@ import com.google.pubsub.v1.ListTopicsResponse; import com.google.pubsub.v1.MessageStoragePolicy; import com.google.pubsub.v1.ProjectName; -import com.google.pubsub.v1.ProjectSubscriptionName; import com.google.pubsub.v1.PublishRequest; import com.google.pubsub.v1.PublishResponse; import com.google.pubsub.v1.PubsubMessage; import com.google.pubsub.v1.SchemaSettings; +import com.google.pubsub.v1.SubscriptionName; import com.google.pubsub.v1.Topic; import com.google.pubsub.v1.TopicName; import com.google.pubsub.v1.UpdateTopicRequest; @@ -764,7 +764,7 @@ public void detachSubscriptionTest() throws Exception { DetachSubscriptionRequest request = DetachSubscriptionRequest.newBuilder() - .setSubscription(ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString()) + .setSubscription(SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString()) .build(); DetachSubscriptionResponse actualResponse = client.detachSubscription(request); @@ -789,7 +789,7 @@ public void detachSubscriptionExceptionTest() throws Exception { try { DetachSubscriptionRequest request = DetachSubscriptionRequest.newBuilder() - .setSubscription(ProjectSubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString()) + .setSubscription(SubscriptionName.of("[PROJECT]", "[SUBSCRIPTION]").toString()) .build(); client.detachSubscription(request); Assert.fail("No exception raised"); diff --git a/grpc-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/PublisherGrpc.java b/owl-bot-staging/v1/grpc-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/PublisherGrpc.java similarity index 50% rename from grpc-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/PublisherGrpc.java rename to owl-bot-staging/v1/grpc-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/PublisherGrpc.java index 380561fd8..ae0f67bad 100644 --- a/grpc-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/PublisherGrpc.java +++ b/owl-bot-staging/v1/grpc-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/PublisherGrpc.java @@ -1,25 +1,8 @@ -/* - * 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. - * You may obtain a copy of the License at - * - * https://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ package com.google.pubsub.v1; import static io.grpc.MethodDescriptor.generateFullMethodName; /** - * - * * * The service that an application uses to manipulate topics, and to send * messages to a topic. @@ -35,518 +18,401 @@ private PublisherGrpc() {} public static final String SERVICE_NAME = "google.pubsub.v1.Publisher"; // Static method descriptors that strictly reflect the proto. - private static volatile io.grpc.MethodDescriptor< - com.google.pubsub.v1.Topic, com.google.pubsub.v1.Topic> - getCreateTopicMethod; + private static volatile io.grpc.MethodDescriptorgetCreateTopicMethod; @io.grpc.stub.annotations.RpcMethod( fullMethodName = SERVICE_NAME + '/' + "CreateTopic", requestType = com.google.pubsub.v1.Topic.class, responseType = com.google.pubsub.v1.Topic.class, methodType = io.grpc.MethodDescriptor.MethodType.UNARY) - public static io.grpc.MethodDescriptor - getCreateTopicMethod() { - io.grpc.MethodDescriptor - getCreateTopicMethod; + public static io.grpc.MethodDescriptor getCreateTopicMethod() { + io.grpc.MethodDescriptor getCreateTopicMethod; if ((getCreateTopicMethod = PublisherGrpc.getCreateTopicMethod) == null) { synchronized (PublisherGrpc.class) { if ((getCreateTopicMethod = PublisherGrpc.getCreateTopicMethod) == null) { - PublisherGrpc.getCreateTopicMethod = - getCreateTopicMethod = - io.grpc.MethodDescriptor - . newBuilder() - .setType(io.grpc.MethodDescriptor.MethodType.UNARY) - .setFullMethodName(generateFullMethodName(SERVICE_NAME, "CreateTopic")) - .setSampledToLocalTracing(true) - .setRequestMarshaller( - io.grpc.protobuf.ProtoUtils.marshaller( - com.google.pubsub.v1.Topic.getDefaultInstance())) - .setResponseMarshaller( - io.grpc.protobuf.ProtoUtils.marshaller( - com.google.pubsub.v1.Topic.getDefaultInstance())) - .setSchemaDescriptor(new PublisherMethodDescriptorSupplier("CreateTopic")) - .build(); + PublisherGrpc.getCreateTopicMethod = getCreateTopicMethod = + io.grpc.MethodDescriptor. newBuilder() + .setType(io.grpc.MethodDescriptor.MethodType.UNARY) + .setFullMethodName(generateFullMethodName(SERVICE_NAME, "CreateTopic")) + .setSampledToLocalTracing(true) + .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( + com.google.pubsub.v1.Topic.getDefaultInstance())) + .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( + com.google.pubsub.v1.Topic.getDefaultInstance())) + .setSchemaDescriptor(new PublisherMethodDescriptorSupplier("CreateTopic")) + .build(); } } } return getCreateTopicMethod; } - private static volatile io.grpc.MethodDescriptor< - com.google.pubsub.v1.UpdateTopicRequest, com.google.pubsub.v1.Topic> - getUpdateTopicMethod; + private static volatile io.grpc.MethodDescriptor getUpdateTopicMethod; @io.grpc.stub.annotations.RpcMethod( fullMethodName = SERVICE_NAME + '/' + "UpdateTopic", requestType = com.google.pubsub.v1.UpdateTopicRequest.class, responseType = com.google.pubsub.v1.Topic.class, methodType = io.grpc.MethodDescriptor.MethodType.UNARY) - public static io.grpc.MethodDescriptor< - com.google.pubsub.v1.UpdateTopicRequest, com.google.pubsub.v1.Topic> - getUpdateTopicMethod() { - io.grpc.MethodDescriptor - getUpdateTopicMethod; + public static io.grpc.MethodDescriptor getUpdateTopicMethod() { + io.grpc.MethodDescriptor getUpdateTopicMethod; if ((getUpdateTopicMethod = PublisherGrpc.getUpdateTopicMethod) == null) { synchronized (PublisherGrpc.class) { if ((getUpdateTopicMethod = PublisherGrpc.getUpdateTopicMethod) == null) { - PublisherGrpc.getUpdateTopicMethod = - getUpdateTopicMethod = - io.grpc.MethodDescriptor - . - newBuilder() - .setType(io.grpc.MethodDescriptor.MethodType.UNARY) - .setFullMethodName(generateFullMethodName(SERVICE_NAME, "UpdateTopic")) - .setSampledToLocalTracing(true) - .setRequestMarshaller( - io.grpc.protobuf.ProtoUtils.marshaller( - com.google.pubsub.v1.UpdateTopicRequest.getDefaultInstance())) - .setResponseMarshaller( - io.grpc.protobuf.ProtoUtils.marshaller( - com.google.pubsub.v1.Topic.getDefaultInstance())) - .setSchemaDescriptor(new PublisherMethodDescriptorSupplier("UpdateTopic")) - .build(); + PublisherGrpc.getUpdateTopicMethod = getUpdateTopicMethod = + io.grpc.MethodDescriptor. newBuilder() + .setType(io.grpc.MethodDescriptor.MethodType.UNARY) + .setFullMethodName(generateFullMethodName(SERVICE_NAME, "UpdateTopic")) + .setSampledToLocalTracing(true) + .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( + com.google.pubsub.v1.UpdateTopicRequest.getDefaultInstance())) + .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( + com.google.pubsub.v1.Topic.getDefaultInstance())) + .setSchemaDescriptor(new PublisherMethodDescriptorSupplier("UpdateTopic")) + .build(); } } } return getUpdateTopicMethod; } - private static volatile io.grpc.MethodDescriptor< - com.google.pubsub.v1.PublishRequest, com.google.pubsub.v1.PublishResponse> - getPublishMethod; + private static volatile io.grpc.MethodDescriptor getPublishMethod; @io.grpc.stub.annotations.RpcMethod( fullMethodName = SERVICE_NAME + '/' + "Publish", requestType = com.google.pubsub.v1.PublishRequest.class, responseType = com.google.pubsub.v1.PublishResponse.class, methodType = io.grpc.MethodDescriptor.MethodType.UNARY) - public static io.grpc.MethodDescriptor< - com.google.pubsub.v1.PublishRequest, com.google.pubsub.v1.PublishResponse> - getPublishMethod() { - io.grpc.MethodDescriptor< - com.google.pubsub.v1.PublishRequest, com.google.pubsub.v1.PublishResponse> - getPublishMethod; + public static io.grpc.MethodDescriptor getPublishMethod() { + io.grpc.MethodDescriptor getPublishMethod; if ((getPublishMethod = PublisherGrpc.getPublishMethod) == null) { synchronized (PublisherGrpc.class) { if ((getPublishMethod = PublisherGrpc.getPublishMethod) == null) { - PublisherGrpc.getPublishMethod = - getPublishMethod = - io.grpc.MethodDescriptor - . - newBuilder() - .setType(io.grpc.MethodDescriptor.MethodType.UNARY) - .setFullMethodName(generateFullMethodName(SERVICE_NAME, "Publish")) - .setSampledToLocalTracing(true) - .setRequestMarshaller( - io.grpc.protobuf.ProtoUtils.marshaller( - com.google.pubsub.v1.PublishRequest.getDefaultInstance())) - .setResponseMarshaller( - io.grpc.protobuf.ProtoUtils.marshaller( - com.google.pubsub.v1.PublishResponse.getDefaultInstance())) - .setSchemaDescriptor(new PublisherMethodDescriptorSupplier("Publish")) - .build(); + PublisherGrpc.getPublishMethod = getPublishMethod = + io.grpc.MethodDescriptor. newBuilder() + .setType(io.grpc.MethodDescriptor.MethodType.UNARY) + .setFullMethodName(generateFullMethodName(SERVICE_NAME, "Publish")) + .setSampledToLocalTracing(true) + .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( + com.google.pubsub.v1.PublishRequest.getDefaultInstance())) + .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( + com.google.pubsub.v1.PublishResponse.getDefaultInstance())) + .setSchemaDescriptor(new PublisherMethodDescriptorSupplier("Publish")) + .build(); } } } return getPublishMethod; } - private static volatile io.grpc.MethodDescriptor< - com.google.pubsub.v1.GetTopicRequest, com.google.pubsub.v1.Topic> - getGetTopicMethod; + private static volatile io.grpc.MethodDescriptor getGetTopicMethod; @io.grpc.stub.annotations.RpcMethod( fullMethodName = SERVICE_NAME + '/' + "GetTopic", requestType = com.google.pubsub.v1.GetTopicRequest.class, responseType = com.google.pubsub.v1.Topic.class, methodType = io.grpc.MethodDescriptor.MethodType.UNARY) - public static io.grpc.MethodDescriptor< - com.google.pubsub.v1.GetTopicRequest, com.google.pubsub.v1.Topic> - getGetTopicMethod() { - io.grpc.MethodDescriptor - getGetTopicMethod; + public static io.grpc.MethodDescriptor getGetTopicMethod() { + io.grpc.MethodDescriptor getGetTopicMethod; if ((getGetTopicMethod = PublisherGrpc.getGetTopicMethod) == null) { synchronized (PublisherGrpc.class) { if ((getGetTopicMethod = PublisherGrpc.getGetTopicMethod) == null) { - PublisherGrpc.getGetTopicMethod = - getGetTopicMethod = - io.grpc.MethodDescriptor - . - newBuilder() - .setType(io.grpc.MethodDescriptor.MethodType.UNARY) - .setFullMethodName(generateFullMethodName(SERVICE_NAME, "GetTopic")) - .setSampledToLocalTracing(true) - .setRequestMarshaller( - io.grpc.protobuf.ProtoUtils.marshaller( - com.google.pubsub.v1.GetTopicRequest.getDefaultInstance())) - .setResponseMarshaller( - io.grpc.protobuf.ProtoUtils.marshaller( - com.google.pubsub.v1.Topic.getDefaultInstance())) - .setSchemaDescriptor(new PublisherMethodDescriptorSupplier("GetTopic")) - .build(); + PublisherGrpc.getGetTopicMethod = getGetTopicMethod = + io.grpc.MethodDescriptor. newBuilder() + .setType(io.grpc.MethodDescriptor.MethodType.UNARY) + .setFullMethodName(generateFullMethodName(SERVICE_NAME, "GetTopic")) + .setSampledToLocalTracing(true) + .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( + com.google.pubsub.v1.GetTopicRequest.getDefaultInstance())) + .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( + com.google.pubsub.v1.Topic.getDefaultInstance())) + .setSchemaDescriptor(new PublisherMethodDescriptorSupplier("GetTopic")) + .build(); } } } return getGetTopicMethod; } - private static volatile io.grpc.MethodDescriptor< - com.google.pubsub.v1.ListTopicsRequest, com.google.pubsub.v1.ListTopicsResponse> - getListTopicsMethod; + private static volatile io.grpc.MethodDescriptor getListTopicsMethod; @io.grpc.stub.annotations.RpcMethod( fullMethodName = SERVICE_NAME + '/' + "ListTopics", requestType = com.google.pubsub.v1.ListTopicsRequest.class, responseType = com.google.pubsub.v1.ListTopicsResponse.class, methodType = io.grpc.MethodDescriptor.MethodType.UNARY) - public static io.grpc.MethodDescriptor< - com.google.pubsub.v1.ListTopicsRequest, com.google.pubsub.v1.ListTopicsResponse> - getListTopicsMethod() { - io.grpc.MethodDescriptor< - com.google.pubsub.v1.ListTopicsRequest, com.google.pubsub.v1.ListTopicsResponse> - getListTopicsMethod; + public static io.grpc.MethodDescriptor getListTopicsMethod() { + io.grpc.MethodDescriptor getListTopicsMethod; if ((getListTopicsMethod = PublisherGrpc.getListTopicsMethod) == null) { synchronized (PublisherGrpc.class) { if ((getListTopicsMethod = PublisherGrpc.getListTopicsMethod) == null) { - PublisherGrpc.getListTopicsMethod = - getListTopicsMethod = - io.grpc.MethodDescriptor - . - newBuilder() - .setType(io.grpc.MethodDescriptor.MethodType.UNARY) - .setFullMethodName(generateFullMethodName(SERVICE_NAME, "ListTopics")) - .setSampledToLocalTracing(true) - .setRequestMarshaller( - io.grpc.protobuf.ProtoUtils.marshaller( - com.google.pubsub.v1.ListTopicsRequest.getDefaultInstance())) - .setResponseMarshaller( - io.grpc.protobuf.ProtoUtils.marshaller( - com.google.pubsub.v1.ListTopicsResponse.getDefaultInstance())) - .setSchemaDescriptor(new PublisherMethodDescriptorSupplier("ListTopics")) - .build(); + PublisherGrpc.getListTopicsMethod = getListTopicsMethod = + io.grpc.MethodDescriptor. newBuilder() + .setType(io.grpc.MethodDescriptor.MethodType.UNARY) + .setFullMethodName(generateFullMethodName(SERVICE_NAME, "ListTopics")) + .setSampledToLocalTracing(true) + .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( + com.google.pubsub.v1.ListTopicsRequest.getDefaultInstance())) + .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( + com.google.pubsub.v1.ListTopicsResponse.getDefaultInstance())) + .setSchemaDescriptor(new PublisherMethodDescriptorSupplier("ListTopics")) + .build(); } } } return getListTopicsMethod; } - private static volatile io.grpc.MethodDescriptor< - com.google.pubsub.v1.ListTopicSubscriptionsRequest, - com.google.pubsub.v1.ListTopicSubscriptionsResponse> - getListTopicSubscriptionsMethod; + private static volatile io.grpc.MethodDescriptor getListTopicSubscriptionsMethod; @io.grpc.stub.annotations.RpcMethod( fullMethodName = SERVICE_NAME + '/' + "ListTopicSubscriptions", requestType = com.google.pubsub.v1.ListTopicSubscriptionsRequest.class, responseType = com.google.pubsub.v1.ListTopicSubscriptionsResponse.class, methodType = io.grpc.MethodDescriptor.MethodType.UNARY) - public static io.grpc.MethodDescriptor< - com.google.pubsub.v1.ListTopicSubscriptionsRequest, - com.google.pubsub.v1.ListTopicSubscriptionsResponse> - getListTopicSubscriptionsMethod() { - io.grpc.MethodDescriptor< - com.google.pubsub.v1.ListTopicSubscriptionsRequest, - com.google.pubsub.v1.ListTopicSubscriptionsResponse> - getListTopicSubscriptionsMethod; + public static io.grpc.MethodDescriptor getListTopicSubscriptionsMethod() { + io.grpc.MethodDescriptor getListTopicSubscriptionsMethod; if ((getListTopicSubscriptionsMethod = PublisherGrpc.getListTopicSubscriptionsMethod) == null) { synchronized (PublisherGrpc.class) { - if ((getListTopicSubscriptionsMethod = PublisherGrpc.getListTopicSubscriptionsMethod) - == null) { - PublisherGrpc.getListTopicSubscriptionsMethod = - getListTopicSubscriptionsMethod = - io.grpc.MethodDescriptor - . - newBuilder() - .setType(io.grpc.MethodDescriptor.MethodType.UNARY) - .setFullMethodName( - generateFullMethodName(SERVICE_NAME, "ListTopicSubscriptions")) - .setSampledToLocalTracing(true) - .setRequestMarshaller( - io.grpc.protobuf.ProtoUtils.marshaller( - com.google.pubsub.v1.ListTopicSubscriptionsRequest - .getDefaultInstance())) - .setResponseMarshaller( - io.grpc.protobuf.ProtoUtils.marshaller( - com.google.pubsub.v1.ListTopicSubscriptionsResponse - .getDefaultInstance())) - .setSchemaDescriptor( - new PublisherMethodDescriptorSupplier("ListTopicSubscriptions")) - .build(); + if ((getListTopicSubscriptionsMethod = PublisherGrpc.getListTopicSubscriptionsMethod) == null) { + PublisherGrpc.getListTopicSubscriptionsMethod = getListTopicSubscriptionsMethod = + io.grpc.MethodDescriptor. newBuilder() + .setType(io.grpc.MethodDescriptor.MethodType.UNARY) + .setFullMethodName(generateFullMethodName(SERVICE_NAME, "ListTopicSubscriptions")) + .setSampledToLocalTracing(true) + .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( + com.google.pubsub.v1.ListTopicSubscriptionsRequest.getDefaultInstance())) + .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( + com.google.pubsub.v1.ListTopicSubscriptionsResponse.getDefaultInstance())) + .setSchemaDescriptor(new PublisherMethodDescriptorSupplier("ListTopicSubscriptions")) + .build(); } } } return getListTopicSubscriptionsMethod; } - private static volatile io.grpc.MethodDescriptor< - com.google.pubsub.v1.ListTopicSnapshotsRequest, - com.google.pubsub.v1.ListTopicSnapshotsResponse> - getListTopicSnapshotsMethod; + private static volatile io.grpc.MethodDescriptor getListTopicSnapshotsMethod; @io.grpc.stub.annotations.RpcMethod( fullMethodName = SERVICE_NAME + '/' + "ListTopicSnapshots", requestType = com.google.pubsub.v1.ListTopicSnapshotsRequest.class, responseType = com.google.pubsub.v1.ListTopicSnapshotsResponse.class, methodType = io.grpc.MethodDescriptor.MethodType.UNARY) - public static io.grpc.MethodDescriptor< - com.google.pubsub.v1.ListTopicSnapshotsRequest, - com.google.pubsub.v1.ListTopicSnapshotsResponse> - getListTopicSnapshotsMethod() { - io.grpc.MethodDescriptor< - com.google.pubsub.v1.ListTopicSnapshotsRequest, - com.google.pubsub.v1.ListTopicSnapshotsResponse> - getListTopicSnapshotsMethod; + public static io.grpc.MethodDescriptor getListTopicSnapshotsMethod() { + io.grpc.MethodDescriptor getListTopicSnapshotsMethod; if ((getListTopicSnapshotsMethod = PublisherGrpc.getListTopicSnapshotsMethod) == null) { synchronized (PublisherGrpc.class) { if ((getListTopicSnapshotsMethod = PublisherGrpc.getListTopicSnapshotsMethod) == null) { - PublisherGrpc.getListTopicSnapshotsMethod = - getListTopicSnapshotsMethod = - io.grpc.MethodDescriptor - . - newBuilder() - .setType(io.grpc.MethodDescriptor.MethodType.UNARY) - .setFullMethodName(generateFullMethodName(SERVICE_NAME, "ListTopicSnapshots")) - .setSampledToLocalTracing(true) - .setRequestMarshaller( - io.grpc.protobuf.ProtoUtils.marshaller( - com.google.pubsub.v1.ListTopicSnapshotsRequest.getDefaultInstance())) - .setResponseMarshaller( - io.grpc.protobuf.ProtoUtils.marshaller( - com.google.pubsub.v1.ListTopicSnapshotsResponse.getDefaultInstance())) - .setSchemaDescriptor( - new PublisherMethodDescriptorSupplier("ListTopicSnapshots")) - .build(); + PublisherGrpc.getListTopicSnapshotsMethod = getListTopicSnapshotsMethod = + io.grpc.MethodDescriptor. newBuilder() + .setType(io.grpc.MethodDescriptor.MethodType.UNARY) + .setFullMethodName(generateFullMethodName(SERVICE_NAME, "ListTopicSnapshots")) + .setSampledToLocalTracing(true) + .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( + com.google.pubsub.v1.ListTopicSnapshotsRequest.getDefaultInstance())) + .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( + com.google.pubsub.v1.ListTopicSnapshotsResponse.getDefaultInstance())) + .setSchemaDescriptor(new PublisherMethodDescriptorSupplier("ListTopicSnapshots")) + .build(); } } } return getListTopicSnapshotsMethod; } - private static volatile io.grpc.MethodDescriptor< - com.google.pubsub.v1.DeleteTopicRequest, com.google.protobuf.Empty> - getDeleteTopicMethod; + private static volatile io.grpc.MethodDescriptor getDeleteTopicMethod; @io.grpc.stub.annotations.RpcMethod( fullMethodName = SERVICE_NAME + '/' + "DeleteTopic", requestType = com.google.pubsub.v1.DeleteTopicRequest.class, responseType = com.google.protobuf.Empty.class, methodType = io.grpc.MethodDescriptor.MethodType.UNARY) - public static io.grpc.MethodDescriptor< - com.google.pubsub.v1.DeleteTopicRequest, com.google.protobuf.Empty> - getDeleteTopicMethod() { - io.grpc.MethodDescriptor - getDeleteTopicMethod; + public static io.grpc.MethodDescriptor getDeleteTopicMethod() { + io.grpc.MethodDescriptor getDeleteTopicMethod; if ((getDeleteTopicMethod = PublisherGrpc.getDeleteTopicMethod) == null) { synchronized (PublisherGrpc.class) { if ((getDeleteTopicMethod = PublisherGrpc.getDeleteTopicMethod) == null) { - PublisherGrpc.getDeleteTopicMethod = - getDeleteTopicMethod = - io.grpc.MethodDescriptor - . - newBuilder() - .setType(io.grpc.MethodDescriptor.MethodType.UNARY) - .setFullMethodName(generateFullMethodName(SERVICE_NAME, "DeleteTopic")) - .setSampledToLocalTracing(true) - .setRequestMarshaller( - io.grpc.protobuf.ProtoUtils.marshaller( - com.google.pubsub.v1.DeleteTopicRequest.getDefaultInstance())) - .setResponseMarshaller( - io.grpc.protobuf.ProtoUtils.marshaller( - com.google.protobuf.Empty.getDefaultInstance())) - .setSchemaDescriptor(new PublisherMethodDescriptorSupplier("DeleteTopic")) - .build(); + PublisherGrpc.getDeleteTopicMethod = getDeleteTopicMethod = + io.grpc.MethodDescriptor. newBuilder() + .setType(io.grpc.MethodDescriptor.MethodType.UNARY) + .setFullMethodName(generateFullMethodName(SERVICE_NAME, "DeleteTopic")) + .setSampledToLocalTracing(true) + .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( + com.google.pubsub.v1.DeleteTopicRequest.getDefaultInstance())) + .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( + com.google.protobuf.Empty.getDefaultInstance())) + .setSchemaDescriptor(new PublisherMethodDescriptorSupplier("DeleteTopic")) + .build(); } } } return getDeleteTopicMethod; } - private static volatile io.grpc.MethodDescriptor< - com.google.pubsub.v1.DetachSubscriptionRequest, - com.google.pubsub.v1.DetachSubscriptionResponse> - getDetachSubscriptionMethod; + private static volatile io.grpc.MethodDescriptor getDetachSubscriptionMethod; @io.grpc.stub.annotations.RpcMethod( fullMethodName = SERVICE_NAME + '/' + "DetachSubscription", requestType = com.google.pubsub.v1.DetachSubscriptionRequest.class, responseType = com.google.pubsub.v1.DetachSubscriptionResponse.class, methodType = io.grpc.MethodDescriptor.MethodType.UNARY) - public static io.grpc.MethodDescriptor< - com.google.pubsub.v1.DetachSubscriptionRequest, - com.google.pubsub.v1.DetachSubscriptionResponse> - getDetachSubscriptionMethod() { - io.grpc.MethodDescriptor< - com.google.pubsub.v1.DetachSubscriptionRequest, - com.google.pubsub.v1.DetachSubscriptionResponse> - getDetachSubscriptionMethod; + public static io.grpc.MethodDescriptor getDetachSubscriptionMethod() { + io.grpc.MethodDescriptor getDetachSubscriptionMethod; if ((getDetachSubscriptionMethod = PublisherGrpc.getDetachSubscriptionMethod) == null) { synchronized (PublisherGrpc.class) { if ((getDetachSubscriptionMethod = PublisherGrpc.getDetachSubscriptionMethod) == null) { - PublisherGrpc.getDetachSubscriptionMethod = - getDetachSubscriptionMethod = - io.grpc.MethodDescriptor - . - newBuilder() - .setType(io.grpc.MethodDescriptor.MethodType.UNARY) - .setFullMethodName(generateFullMethodName(SERVICE_NAME, "DetachSubscription")) - .setSampledToLocalTracing(true) - .setRequestMarshaller( - io.grpc.protobuf.ProtoUtils.marshaller( - com.google.pubsub.v1.DetachSubscriptionRequest.getDefaultInstance())) - .setResponseMarshaller( - io.grpc.protobuf.ProtoUtils.marshaller( - com.google.pubsub.v1.DetachSubscriptionResponse.getDefaultInstance())) - .setSchemaDescriptor( - new PublisherMethodDescriptorSupplier("DetachSubscription")) - .build(); + PublisherGrpc.getDetachSubscriptionMethod = getDetachSubscriptionMethod = + io.grpc.MethodDescriptor. newBuilder() + .setType(io.grpc.MethodDescriptor.MethodType.UNARY) + .setFullMethodName(generateFullMethodName(SERVICE_NAME, "DetachSubscription")) + .setSampledToLocalTracing(true) + .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( + com.google.pubsub.v1.DetachSubscriptionRequest.getDefaultInstance())) + .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( + com.google.pubsub.v1.DetachSubscriptionResponse.getDefaultInstance())) + .setSchemaDescriptor(new PublisherMethodDescriptorSupplier("DetachSubscription")) + .build(); } } } return getDetachSubscriptionMethod; } - /** Creates a new async stub that supports all call types for the service */ + /** + * Creates a new async stub that supports all call types for the service + */ public static PublisherStub newStub(io.grpc.Channel channel) { io.grpc.stub.AbstractStub.StubFactory factory = - new io.grpc.stub.AbstractStub.StubFactory () { - @java.lang.Override - public PublisherStub newStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) { - return new PublisherStub(channel, callOptions); - } - }; + new io.grpc.stub.AbstractStub.StubFactory () { + @java.lang.Override + public PublisherStub newStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) { + return new PublisherStub(channel, callOptions); + } + }; return PublisherStub.newStub(factory, channel); } /** * Creates a new blocking-style stub that supports unary and streaming output calls on the service */ - public static PublisherBlockingStub newBlockingStub(io.grpc.Channel channel) { + public static PublisherBlockingStub newBlockingStub( + io.grpc.Channel channel) { io.grpc.stub.AbstractStub.StubFactory factory = - new io.grpc.stub.AbstractStub.StubFactory () { - @java.lang.Override - public PublisherBlockingStub newStub( - io.grpc.Channel channel, io.grpc.CallOptions callOptions) { - return new PublisherBlockingStub(channel, callOptions); - } - }; + new io.grpc.stub.AbstractStub.StubFactory () { + @java.lang.Override + public PublisherBlockingStub newStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) { + return new PublisherBlockingStub(channel, callOptions); + } + }; return PublisherBlockingStub.newStub(factory, channel); } - /** Creates a new ListenableFuture-style stub that supports unary calls on the service */ - public static PublisherFutureStub newFutureStub(io.grpc.Channel channel) { + /** + * Creates a new ListenableFuture-style stub that supports unary calls on the service + */ + public static PublisherFutureStub newFutureStub( + io.grpc.Channel channel) { io.grpc.stub.AbstractStub.StubFactory factory = - new io.grpc.stub.AbstractStub.StubFactory () { - @java.lang.Override - public PublisherFutureStub newStub( - io.grpc.Channel channel, io.grpc.CallOptions callOptions) { - return new PublisherFutureStub(channel, callOptions); - } - }; + new io.grpc.stub.AbstractStub.StubFactory () { + @java.lang.Override + public PublisherFutureStub newStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) { + return new PublisherFutureStub(channel, callOptions); + } + }; return PublisherFutureStub.newStub(factory, channel); } /** - * - * * * The service that an application uses to manipulate topics, and to send * messages to a topic. **/ - public abstract static class PublisherImplBase implements io.grpc.BindableService { + public static abstract class PublisherImplBase implements io.grpc.BindableService { /** - * - * ** Creates the given topic with the given name. See the [resource name rules] * (https://cloud.google.com/pubsub/docs/admin#resource_names). **/ - public void createTopic( - com.google.pubsub.v1.Topic request, + public void createTopic(com.google.pubsub.v1.Topic request, io.grpc.stub.StreamObserverresponseObserver) { - io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall( - getCreateTopicMethod(), responseObserver); + io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getCreateTopicMethod(), responseObserver); } /** - * - * * * Updates an existing topic. Note that certain properties of a * topic are not modifiable. **/ - public void updateTopic( - com.google.pubsub.v1.UpdateTopicRequest request, + public void updateTopic(com.google.pubsub.v1.UpdateTopicRequest request, io.grpc.stub.StreamObserverresponseObserver) { - io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall( - getUpdateTopicMethod(), responseObserver); + io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getUpdateTopicMethod(), responseObserver); } /** - * - * * * Adds one or more messages to the topic. Returns `NOT_FOUND` if the topic * does not exist. **/ - public void publish( - com.google.pubsub.v1.PublishRequest request, + public void publish(com.google.pubsub.v1.PublishRequest request, io.grpc.stub.StreamObserverresponseObserver) { io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getPublishMethod(), responseObserver); } /** - * - * * * Gets the configuration of a topic. **/ - public void getTopic( - com.google.pubsub.v1.GetTopicRequest request, + public void getTopic(com.google.pubsub.v1.GetTopicRequest request, io.grpc.stub.StreamObserverresponseObserver) { io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getGetTopicMethod(), responseObserver); } /** - * - * * * Lists matching topics. **/ - public void listTopics( - com.google.pubsub.v1.ListTopicsRequest request, + public void listTopics(com.google.pubsub.v1.ListTopicsRequest request, io.grpc.stub.StreamObserverresponseObserver) { io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getListTopicsMethod(), responseObserver); } /** - * - * *