getIamPolicySettin
return testIamPermissionsSettings;
}
+ /** Returns the endpoint set by the user or the the service's default endpoint. */
+ @Override
+ public String getEndpoint() {
+ if (super.getEndpoint() != null) {
+ return super.getEndpoint();
+ }
+ return getDefaultEndpoint();
+ }
+
@Override
public SubscriberStubSettings build() throws IOException {
return new SubscriberStubSettings(this);
diff --git a/google-cloud-pubsub/src/main/resources/META-INF/native-image/com.google.cloud.pubsub.v1/reflect-config.json b/owl-bot-staging/v1/google-cloud-pubsub/src/main/resources/META-INF/native-image/com.google.cloud.pubsub.v1/reflect-config.json
similarity index 97%
rename from google-cloud-pubsub/src/main/resources/META-INF/native-image/com.google.cloud.pubsub.v1/reflect-config.json
rename to owl-bot-staging/v1/google-cloud-pubsub/src/main/resources/META-INF/native-image/com.google.cloud.pubsub.v1/reflect-config.json
index 8fd73b027..441c326d2 100644
--- a/google-cloud-pubsub/src/main/resources/META-INF/native-image/com.google.cloud.pubsub.v1/reflect-config.json
+++ b/owl-bot-staging/v1/google-cloud-pubsub/src/main/resources/META-INF/native-image/com.google.cloud.pubsub.v1/reflect-config.json
@@ -1691,6 +1691,51 @@
"allDeclaredClasses": true,
"allPublicClasses": true
},
+ {
+ "name": "com.google.pubsub.v1.IngestionDataSourceSettings",
+ "queryAllDeclaredConstructors": true,
+ "queryAllPublicConstructors": true,
+ "queryAllDeclaredMethods": true,
+ "allPublicMethods": true,
+ "allDeclaredClasses": true,
+ "allPublicClasses": true
+ },
+ {
+ "name": "com.google.pubsub.v1.IngestionDataSourceSettings$AwsKinesis",
+ "queryAllDeclaredConstructors": true,
+ "queryAllPublicConstructors": true,
+ "queryAllDeclaredMethods": true,
+ "allPublicMethods": true,
+ "allDeclaredClasses": true,
+ "allPublicClasses": true
+ },
+ {
+ "name": "com.google.pubsub.v1.IngestionDataSourceSettings$AwsKinesis$Builder",
+ "queryAllDeclaredConstructors": true,
+ "queryAllPublicConstructors": true,
+ "queryAllDeclaredMethods": true,
+ "allPublicMethods": true,
+ "allDeclaredClasses": true,
+ "allPublicClasses": true
+ },
+ {
+ "name": "com.google.pubsub.v1.IngestionDataSourceSettings$AwsKinesis$State",
+ "queryAllDeclaredConstructors": true,
+ "queryAllPublicConstructors": true,
+ "queryAllDeclaredMethods": true,
+ "allPublicMethods": true,
+ "allDeclaredClasses": true,
+ "allPublicClasses": true
+ },
+ {
+ "name": "com.google.pubsub.v1.IngestionDataSourceSettings$Builder",
+ "queryAllDeclaredConstructors": true,
+ "queryAllPublicConstructors": true,
+ "queryAllDeclaredMethods": true,
+ "allPublicMethods": true,
+ "allDeclaredClasses": true,
+ "allPublicClasses": true
+ },
{
"name": "com.google.pubsub.v1.ListSchemaRevisionsRequest",
"queryAllDeclaredConstructors": true,
@@ -2456,6 +2501,15 @@
"allDeclaredClasses": true,
"allPublicClasses": true
},
+ {
+ "name": "com.google.pubsub.v1.Topic$State",
+ "queryAllDeclaredConstructors": true,
+ "queryAllPublicConstructors": true,
+ "queryAllDeclaredMethods": true,
+ "allPublicMethods": true,
+ "allDeclaredClasses": true,
+ "allPublicClasses": true
+ },
{
"name": "com.google.pubsub.v1.UpdateSnapshotRequest",
"queryAllDeclaredConstructors": true,
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/SchemaServiceClientHttpJsonTest.java b/owl-bot-staging/v1/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/SchemaServiceClientHttpJsonTest.java
similarity index 100%
rename from google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/SchemaServiceClientHttpJsonTest.java
rename to owl-bot-staging/v1/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/SchemaServiceClientHttpJsonTest.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/SubscriptionAdminClientHttpJsonTest.java b/owl-bot-staging/v1/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/SubscriptionAdminClientHttpJsonTest.java
similarity index 100%
rename from google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/SubscriptionAdminClientHttpJsonTest.java
rename to owl-bot-staging/v1/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/SubscriptionAdminClientHttpJsonTest.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 100%
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
diff --git a/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/TopicAdminClientHttpJsonTest.java b/owl-bot-staging/v1/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/TopicAdminClientHttpJsonTest.java
similarity index 98%
rename from google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/TopicAdminClientHttpJsonTest.java
rename to owl-bot-staging/v1/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/TopicAdminClientHttpJsonTest.java
index c18152b5d..2dc4d6e09 100644
--- a/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/TopicAdminClientHttpJsonTest.java
+++ b/owl-bot-staging/v1/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/TopicAdminClientHttpJsonTest.java
@@ -45,6 +45,7 @@
import com.google.protobuf.FieldMask;
import com.google.pubsub.v1.DetachSubscriptionRequest;
import com.google.pubsub.v1.DetachSubscriptionResponse;
+import com.google.pubsub.v1.IngestionDataSourceSettings;
import com.google.pubsub.v1.ListTopicSnapshotsResponse;
import com.google.pubsub.v1.ListTopicSubscriptionsResponse;
import com.google.pubsub.v1.ListTopicsResponse;
@@ -115,6 +116,7 @@ public void createTopicTest() throws Exception {
.setSchemaSettings(SchemaSettings.newBuilder().build())
.setSatisfiesPzs(true)
.setMessageRetentionDuration(Duration.newBuilder().build())
+ .setIngestionDataSourceSettings(IngestionDataSourceSettings.newBuilder().build())
.build();
mockService.addResponse(expectedResponse);
@@ -165,6 +167,7 @@ public void createTopicTest2() throws Exception {
.setSchemaSettings(SchemaSettings.newBuilder().build())
.setSatisfiesPzs(true)
.setMessageRetentionDuration(Duration.newBuilder().build())
+ .setIngestionDataSourceSettings(IngestionDataSourceSettings.newBuilder().build())
.build();
mockService.addResponse(expectedResponse);
@@ -215,6 +218,7 @@ public void updateTopicTest() throws Exception {
.setSchemaSettings(SchemaSettings.newBuilder().build())
.setSatisfiesPzs(true)
.setMessageRetentionDuration(Duration.newBuilder().build())
+ .setIngestionDataSourceSettings(IngestionDataSourceSettings.newBuilder().build())
.build();
mockService.addResponse(expectedResponse);
@@ -227,6 +231,7 @@ public void updateTopicTest() throws Exception {
.setSchemaSettings(SchemaSettings.newBuilder().build())
.setSatisfiesPzs(true)
.setMessageRetentionDuration(Duration.newBuilder().build())
+ .setIngestionDataSourceSettings(IngestionDataSourceSettings.newBuilder().build())
.build();
FieldMask updateMask = FieldMask.newBuilder().build();
@@ -265,6 +270,7 @@ public void updateTopicExceptionTest() throws Exception {
.setSchemaSettings(SchemaSettings.newBuilder().build())
.setSatisfiesPzs(true)
.setMessageRetentionDuration(Duration.newBuilder().build())
+ .setIngestionDataSourceSettings(IngestionDataSourceSettings.newBuilder().build())
.build();
FieldMask updateMask = FieldMask.newBuilder().build();
client.updateTopic(topic, updateMask);
@@ -373,6 +379,7 @@ public void getTopicTest() throws Exception {
.setSchemaSettings(SchemaSettings.newBuilder().build())
.setSatisfiesPzs(true)
.setMessageRetentionDuration(Duration.newBuilder().build())
+ .setIngestionDataSourceSettings(IngestionDataSourceSettings.newBuilder().build())
.build();
mockService.addResponse(expectedResponse);
@@ -423,6 +430,7 @@ public void getTopicTest2() throws Exception {
.setSchemaSettings(SchemaSettings.newBuilder().build())
.setSatisfiesPzs(true)
.setMessageRetentionDuration(Duration.newBuilder().build())
+ .setIngestionDataSourceSettings(IngestionDataSourceSettings.newBuilder().build())
.build();
mockService.addResponse(expectedResponse);
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 98%
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 1693f7e40..44a9c11c5 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
@@ -45,6 +45,7 @@
import com.google.pubsub.v1.DetachSubscriptionRequest;
import com.google.pubsub.v1.DetachSubscriptionResponse;
import com.google.pubsub.v1.GetTopicRequest;
+import com.google.pubsub.v1.IngestionDataSourceSettings;
import com.google.pubsub.v1.ListTopicSnapshotsRequest;
import com.google.pubsub.v1.ListTopicSnapshotsResponse;
import com.google.pubsub.v1.ListTopicSubscriptionsRequest;
@@ -129,6 +130,7 @@ public void createTopicTest() throws Exception {
.setSchemaSettings(SchemaSettings.newBuilder().build())
.setSatisfiesPzs(true)
.setMessageRetentionDuration(Duration.newBuilder().build())
+ .setIngestionDataSourceSettings(IngestionDataSourceSettings.newBuilder().build())
.build();
mockPublisher.addResponse(expectedResponse);
@@ -173,6 +175,7 @@ public void createTopicTest2() throws Exception {
.setSchemaSettings(SchemaSettings.newBuilder().build())
.setSatisfiesPzs(true)
.setMessageRetentionDuration(Duration.newBuilder().build())
+ .setIngestionDataSourceSettings(IngestionDataSourceSettings.newBuilder().build())
.build();
mockPublisher.addResponse(expectedResponse);
@@ -217,6 +220,7 @@ public void updateTopicTest() throws Exception {
.setSchemaSettings(SchemaSettings.newBuilder().build())
.setSatisfiesPzs(true)
.setMessageRetentionDuration(Duration.newBuilder().build())
+ .setIngestionDataSourceSettings(IngestionDataSourceSettings.newBuilder().build())
.build();
mockPublisher.addResponse(expectedResponse);
@@ -342,6 +346,7 @@ public void getTopicTest() throws Exception {
.setSchemaSettings(SchemaSettings.newBuilder().build())
.setSatisfiesPzs(true)
.setMessageRetentionDuration(Duration.newBuilder().build())
+ .setIngestionDataSourceSettings(IngestionDataSourceSettings.newBuilder().build())
.build();
mockPublisher.addResponse(expectedResponse);
@@ -386,6 +391,7 @@ public void getTopicTest2() throws Exception {
.setSchemaSettings(SchemaSettings.newBuilder().build())
.setSatisfiesPzs(true)
.setMessageRetentionDuration(Duration.newBuilder().build())
+ .setIngestionDataSourceSettings(IngestionDataSourceSettings.newBuilder().build())
.build();
mockPublisher.addResponse(expectedResponse);
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 51%
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 020bf6f9d..8d000f1dd 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 2023 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.
@@ -36,423 +19,330 @@ private PublisherGrpc() {}
public static final java.lang.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.MethodDescriptor getCreateTopicMethod;
@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.
@@ -461,93 +351,69 @@ public PublisherFutureStub newStub(
public interface AsyncService {
/**
- *
- *
*
* Creates the given topic with the given name. See the [resource name rules]
* (https://cloud.google.com/pubsub/docs/pubsub-basics#resource_names).
*
*/
- default void createTopic(
- com.google.pubsub.v1.Topic request,
+ default void createTopic(com.google.pubsub.v1.Topic request,
io.grpc.stub.StreamObserver responseObserver) {
- 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.
*
*/
- default void updateTopic(
- com.google.pubsub.v1.UpdateTopicRequest request,
+ default void updateTopic(com.google.pubsub.v1.UpdateTopicRequest request,
io.grpc.stub.StreamObserver responseObserver) {
- 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.
*
*/
- default void publish(
- com.google.pubsub.v1.PublishRequest request,
+ default void publish(com.google.pubsub.v1.PublishRequest request,
io.grpc.stub.StreamObserver responseObserver) {
io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getPublishMethod(), responseObserver);
}
/**
- *
- *
*
* Gets the configuration of a topic.
*
*/
- default void getTopic(
- com.google.pubsub.v1.GetTopicRequest request,
+ default void getTopic(com.google.pubsub.v1.GetTopicRequest request,
io.grpc.stub.StreamObserver responseObserver) {
io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getGetTopicMethod(), responseObserver);
}
/**
- *
- *
*
* Lists matching topics.
*
*/
- default void listTopics(
- com.google.pubsub.v1.ListTopicsRequest request,
+ default void listTopics(com.google.pubsub.v1.ListTopicsRequest request,
io.grpc.stub.StreamObserver responseObserver) {
io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getListTopicsMethod(), responseObserver);
}
/**
- *
- *
*
* Lists the names of the attached subscriptions on this topic.
*
*/
- default void listTopicSubscriptions(
- com.google.pubsub.v1.ListTopicSubscriptionsRequest request,
- io.grpc.stub.StreamObserver
- responseObserver) {
- io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
- getListTopicSubscriptionsMethod(), responseObserver);
+ default void listTopicSubscriptions(com.google.pubsub.v1.ListTopicSubscriptionsRequest request,
+ io.grpc.stub.StreamObserver responseObserver) {
+ io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getListTopicSubscriptionsMethod(), responseObserver);
}
/**
- *
- *
*
* Lists the names of the snapshots on this topic. Snapshots are used in
* [Seek](https://cloud.google.com/pubsub/docs/replay-overview) operations,
@@ -556,17 +422,12 @@ default void listTopicSubscriptions(
* state captured by a snapshot.
*
*/
- default void listTopicSnapshots(
- com.google.pubsub.v1.ListTopicSnapshotsRequest request,
- io.grpc.stub.StreamObserver
- responseObserver) {
- io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
- getListTopicSnapshotsMethod(), responseObserver);
+ default void listTopicSnapshots(com.google.pubsub.v1.ListTopicSnapshotsRequest request,
+ io.grpc.stub.StreamObserver responseObserver) {
+ io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getListTopicSnapshotsMethod(), responseObserver);
}
/**
- *
- *
*
* 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
@@ -575,16 +436,12 @@ default void listTopicSnapshots(
* not deleted, but their `topic` field is set to `_deleted-topic_`.
*
*/
- default void deleteTopic(
- com.google.pubsub.v1.DeleteTopicRequest request,
+ default void deleteTopic(com.google.pubsub.v1.DeleteTopicRequest request,
io.grpc.stub.StreamObserver responseObserver) {
- io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
- getDeleteTopicMethod(), responseObserver);
+ io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getDeleteTopicMethod(), responseObserver);
}
/**
- *
- *
*
* Detaches a subscription from this topic. All messages retained in the
* subscription are dropped. Subsequent `Pull` and `StreamingPull` requests
@@ -592,146 +449,117 @@ default void deleteTopic(
* subscription, pushes to the endpoint will stop.
*
*/
- default void detachSubscription(
- com.google.pubsub.v1.DetachSubscriptionRequest request,
- io.grpc.stub.StreamObserver
- responseObserver) {
- io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
- getDetachSubscriptionMethod(), responseObserver);
+ default void detachSubscription(com.google.pubsub.v1.DetachSubscriptionRequest request,
+ io.grpc.stub.StreamObserver responseObserver) {
+ io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getDetachSubscriptionMethod(), responseObserver);
}
}
/**
* Base class for the server implementation of the service Publisher.
- *
*
* 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, AsyncService {
+ public static abstract class PublisherImplBase
+ implements io.grpc.BindableService, AsyncService {
- @java.lang.Override
- public final io.grpc.ServerServiceDefinition bindService() {
+ @java.lang.Override public final io.grpc.ServerServiceDefinition bindService() {
return PublisherGrpc.bindService(this);
}
}
/**
* A stub to allow clients to do asynchronous rpc calls to service Publisher.
- *
*
* The service that an application uses to manipulate topics, and to send
* messages to a topic.
*
*/
- public static final class PublisherStub extends io.grpc.stub.AbstractAsyncStub {
- private PublisherStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
+ public static final class PublisherStub
+ extends io.grpc.stub.AbstractAsyncStub {
+ private PublisherStub(
+ io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
super(channel, callOptions);
}
@java.lang.Override
- protected PublisherStub build(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
+ protected PublisherStub build(
+ io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
return new PublisherStub(channel, callOptions);
}
/**
- *
- *
*
* Creates the given topic with the given name. See the [resource name rules]
* (https://cloud.google.com/pubsub/docs/pubsub-basics#resource_names).
*
*/
- public void createTopic(
- com.google.pubsub.v1.Topic request,
+ public void createTopic(com.google.pubsub.v1.Topic request,
io.grpc.stub.StreamObserver responseObserver) {
io.grpc.stub.ClientCalls.asyncUnaryCall(
- getChannel().newCall(getCreateTopicMethod(), getCallOptions()),
- request,
- responseObserver);
+ getChannel().newCall(getCreateTopicMethod(), getCallOptions()), request, 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.StreamObserver responseObserver) {
io.grpc.stub.ClientCalls.asyncUnaryCall(
- getChannel().newCall(getUpdateTopicMethod(), getCallOptions()),
- request,
- responseObserver);
+ getChannel().newCall(getUpdateTopicMethod(), getCallOptions()), request, 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.StreamObserver responseObserver) {
io.grpc.stub.ClientCalls.asyncUnaryCall(
getChannel().newCall(getPublishMethod(), getCallOptions()), request, 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.StreamObserver responseObserver) {
io.grpc.stub.ClientCalls.asyncUnaryCall(
getChannel().newCall(getGetTopicMethod(), getCallOptions()), request, 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.StreamObserver responseObserver) {
io.grpc.stub.ClientCalls.asyncUnaryCall(
getChannel().newCall(getListTopicsMethod(), getCallOptions()), request, responseObserver);
}
/**
- *
- *
*
* Lists the names of the attached subscriptions on this topic.
*
*/
- public void listTopicSubscriptions(
- com.google.pubsub.v1.ListTopicSubscriptionsRequest request,
- io.grpc.stub.StreamObserver
- responseObserver) {
+ public void listTopicSubscriptions(com.google.pubsub.v1.ListTopicSubscriptionsRequest request,
+ io.grpc.stub.StreamObserver responseObserver) {
io.grpc.stub.ClientCalls.asyncUnaryCall(
- getChannel().newCall(getListTopicSubscriptionsMethod(), getCallOptions()),
- request,
- responseObserver);
+ getChannel().newCall(getListTopicSubscriptionsMethod(), getCallOptions()), request, responseObserver);
}
/**
- *
- *
*
* Lists the names of the snapshots on this topic. Snapshots are used in
* [Seek](https://cloud.google.com/pubsub/docs/replay-overview) operations,
@@ -740,19 +568,13 @@ public void listTopicSubscriptions(
* state captured by a snapshot.
*
*/
- public void listTopicSnapshots(
- com.google.pubsub.v1.ListTopicSnapshotsRequest request,
- io.grpc.stub.StreamObserver
- responseObserver) {
+ public void listTopicSnapshots(com.google.pubsub.v1.ListTopicSnapshotsRequest request,
+ io.grpc.stub.StreamObserver responseObserver) {
io.grpc.stub.ClientCalls.asyncUnaryCall(
- getChannel().newCall(getListTopicSnapshotsMethod(), getCallOptions()),
- request,
- responseObserver);
+ getChannel().newCall(getListTopicSnapshotsMethod(), getCallOptions()), request, responseObserver);
}
/**
- *
- *
*
* 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
@@ -761,18 +583,13 @@ public void listTopicSnapshots(
* not deleted, but their `topic` field is set to `_deleted-topic_`.
*
*/
- public void deleteTopic(
- com.google.pubsub.v1.DeleteTopicRequest request,
+ public void deleteTopic(com.google.pubsub.v1.DeleteTopicRequest request,
io.grpc.stub.StreamObserver responseObserver) {
io.grpc.stub.ClientCalls.asyncUnaryCall(
- getChannel().newCall(getDeleteTopicMethod(), getCallOptions()),
- request,
- responseObserver);
+ getChannel().newCall(getDeleteTopicMethod(), getCallOptions()), request, responseObserver);
}
/**
- *
- *
*
* Detaches a subscription from this topic. All messages retained in the
* subscription are dropped. Subsequent `Pull` and `StreamingPull` requests
@@ -780,20 +597,15 @@ public void deleteTopic(
* subscription, pushes to the endpoint will stop.
*
*/
- public void detachSubscription(
- com.google.pubsub.v1.DetachSubscriptionRequest request,
- io.grpc.stub.StreamObserver
- responseObserver) {
+ public void detachSubscription(com.google.pubsub.v1.DetachSubscriptionRequest request,
+ io.grpc.stub.StreamObserver responseObserver) {
io.grpc.stub.ClientCalls.asyncUnaryCall(
- getChannel().newCall(getDetachSubscriptionMethod(), getCallOptions()),
- request,
- responseObserver);
+ getChannel().newCall(getDetachSubscriptionMethod(), getCallOptions()), request, responseObserver);
}
}
/**
* A stub to allow clients to do synchronous rpc calls to service Publisher.
- *
*
* The service that an application uses to manipulate topics, and to send
* messages to a topic.
@@ -801,7 +613,8 @@ public void detachSubscription(
*/
public static final class PublisherBlockingStub
extends io.grpc.stub.AbstractBlockingStub {
- private PublisherBlockingStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
+ private PublisherBlockingStub(
+ io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
super(channel, callOptions);
}
@@ -812,8 +625,6 @@ protected PublisherBlockingStub build(
}
/**
- *
- *
*
* Creates the given topic with the given name. See the [resource name rules]
* (https://cloud.google.com/pubsub/docs/pubsub-basics#resource_names).
@@ -825,8 +636,6 @@ public com.google.pubsub.v1.Topic createTopic(com.google.pubsub.v1.Topic request
}
/**
- *
- *
*
* Updates an existing topic. Note that certain properties of a
* topic are not modifiable.
@@ -838,22 +647,17 @@ public com.google.pubsub.v1.Topic updateTopic(com.google.pubsub.v1.UpdateTopicRe
}
/**
- *
- *
*
* Adds one or more messages to the topic. Returns `NOT_FOUND` if the topic
* does not exist.
*
*/
- public com.google.pubsub.v1.PublishResponse publish(
- com.google.pubsub.v1.PublishRequest request) {
+ public com.google.pubsub.v1.PublishResponse publish(com.google.pubsub.v1.PublishRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getPublishMethod(), getCallOptions(), request);
}
/**
- *
- *
*
* Gets the configuration of a topic.
*
@@ -864,34 +668,26 @@ public com.google.pubsub.v1.Topic getTopic(com.google.pubsub.v1.GetTopicRequest
}
/**
- *
- *
*
* Lists matching topics.
*
*/
- public com.google.pubsub.v1.ListTopicsResponse listTopics(
- com.google.pubsub.v1.ListTopicsRequest request) {
+ public com.google.pubsub.v1.ListTopicsResponse listTopics(com.google.pubsub.v1.ListTopicsRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getListTopicsMethod(), getCallOptions(), request);
}
/**
- *
- *
*
* Lists the names of the attached subscriptions on this topic.
*
*/
- public com.google.pubsub.v1.ListTopicSubscriptionsResponse listTopicSubscriptions(
- com.google.pubsub.v1.ListTopicSubscriptionsRequest request) {
+ public com.google.pubsub.v1.ListTopicSubscriptionsResponse listTopicSubscriptions(com.google.pubsub.v1.ListTopicSubscriptionsRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getListTopicSubscriptionsMethod(), getCallOptions(), request);
}
/**
- *
- *
*
* Lists the names of the snapshots on this topic. Snapshots are used in
* [Seek](https://cloud.google.com/pubsub/docs/replay-overview) operations,
@@ -900,15 +696,12 @@ public com.google.pubsub.v1.ListTopicSubscriptionsResponse listTopicSubscription
* state captured by a snapshot.
*
*/
- public com.google.pubsub.v1.ListTopicSnapshotsResponse listTopicSnapshots(
- com.google.pubsub.v1.ListTopicSnapshotsRequest request) {
+ public com.google.pubsub.v1.ListTopicSnapshotsResponse listTopicSnapshots(com.google.pubsub.v1.ListTopicSnapshotsRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getListTopicSnapshotsMethod(), getCallOptions(), request);
}
/**
- *
- *
*
* 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
@@ -923,8 +716,6 @@ public com.google.protobuf.Empty deleteTopic(com.google.pubsub.v1.DeleteTopicReq
}
/**
- *
- *
*
* Detaches a subscription from this topic. All messages retained in the
* subscription are dropped. Subsequent `Pull` and `StreamingPull` requests
@@ -932,8 +723,7 @@ public com.google.protobuf.Empty deleteTopic(com.google.pubsub.v1.DeleteTopicReq
* subscription, pushes to the endpoint will stop.
*
*/
- public com.google.pubsub.v1.DetachSubscriptionResponse detachSubscription(
- com.google.pubsub.v1.DetachSubscriptionRequest request) {
+ public com.google.pubsub.v1.DetachSubscriptionResponse detachSubscription(com.google.pubsub.v1.DetachSubscriptionRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getDetachSubscriptionMethod(), getCallOptions(), request);
}
@@ -941,7 +731,6 @@ public com.google.pubsub.v1.DetachSubscriptionResponse detachSubscription(
/**
* A stub to allow clients to do ListenableFuture-style rpc calls to service Publisher.
- *
*
* The service that an application uses to manipulate topics, and to send
* messages to a topic.
@@ -949,60 +738,54 @@ public com.google.pubsub.v1.DetachSubscriptionResponse detachSubscription(
*/
public static final class PublisherFutureStub
extends io.grpc.stub.AbstractFutureStub {
- private PublisherFutureStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
+ private PublisherFutureStub(
+ io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
super(channel, callOptions);
}
@java.lang.Override
- protected PublisherFutureStub build(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
+ protected PublisherFutureStub build(
+ io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
return new PublisherFutureStub(channel, callOptions);
}
/**
- *
- *
*
* Creates the given topic with the given name. See the [resource name rules]
* (https://cloud.google.com/pubsub/docs/pubsub-basics#resource_names).
*
*/
- public com.google.common.util.concurrent.ListenableFuture
- createTopic(com.google.pubsub.v1.Topic request) {
+ public com.google.common.util.concurrent.ListenableFuture createTopic(
+ com.google.pubsub.v1.Topic request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getCreateTopicMethod(), getCallOptions()), request);
}
/**
- *
- *
*
* Updates an existing topic. Note that certain properties of a
* topic are not modifiable.
*
*/
- public com.google.common.util.concurrent.ListenableFuture
- updateTopic(com.google.pubsub.v1.UpdateTopicRequest request) {
+ public com.google.common.util.concurrent.ListenableFuture updateTopic(
+ com.google.pubsub.v1.UpdateTopicRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getUpdateTopicMethod(), getCallOptions()), request);
}
/**
- *
- *
*
* Adds one or more messages to the topic. Returns `NOT_FOUND` if the topic
* does not exist.
*
*/
- public com.google.common.util.concurrent.ListenableFuture
- publish(com.google.pubsub.v1.PublishRequest request) {
+ public com.google.common.util.concurrent.ListenableFuture publish(
+ com.google.pubsub.v1.PublishRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getPublishMethod(), getCallOptions()), request);
}
/**
- *
- *
*
* Gets the configuration of a topic.
*
@@ -1014,36 +797,28 @@ public com.google.common.util.concurrent.ListenableFuture
* Lists matching topics.
*
*/
- public com.google.common.util.concurrent.ListenableFuture<
- com.google.pubsub.v1.ListTopicsResponse>
- listTopics(com.google.pubsub.v1.ListTopicsRequest request) {
+ public com.google.common.util.concurrent.ListenableFuture listTopics(
+ com.google.pubsub.v1.ListTopicsRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getListTopicsMethod(), getCallOptions()), request);
}
/**
- *
- *
*
* Lists the names of the attached subscriptions on this topic.
*
*/
- public com.google.common.util.concurrent.ListenableFuture<
- com.google.pubsub.v1.ListTopicSubscriptionsResponse>
- listTopicSubscriptions(com.google.pubsub.v1.ListTopicSubscriptionsRequest request) {
+ public com.google.common.util.concurrent.ListenableFuture listTopicSubscriptions(
+ com.google.pubsub.v1.ListTopicSubscriptionsRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getListTopicSubscriptionsMethod(), getCallOptions()), request);
}
/**
- *
- *
*
* Lists the names of the snapshots on this topic. Snapshots are used in
* [Seek](https://cloud.google.com/pubsub/docs/replay-overview) operations,
@@ -1052,16 +827,13 @@ public com.google.common.util.concurrent.ListenableFuture
*/
- public com.google.common.util.concurrent.ListenableFuture<
- com.google.pubsub.v1.ListTopicSnapshotsResponse>
- listTopicSnapshots(com.google.pubsub.v1.ListTopicSnapshotsRequest request) {
+ public com.google.common.util.concurrent.ListenableFuture listTopicSnapshots(
+ com.google.pubsub.v1.ListTopicSnapshotsRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getListTopicSnapshotsMethod(), getCallOptions()), request);
}
/**
- *
- *
*
* 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
@@ -1070,15 +842,13 @@ public com.google.common.util.concurrent.ListenableFuture
*/
- public com.google.common.util.concurrent.ListenableFuture
- deleteTopic(com.google.pubsub.v1.DeleteTopicRequest request) {
+ public com.google.common.util.concurrent.ListenableFuture deleteTopic(
+ com.google.pubsub.v1.DeleteTopicRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getDeleteTopicMethod(), getCallOptions()), request);
}
/**
- *
- *
*
* Detaches a subscription from this topic. All messages retained in the
* subscription are dropped. Subsequent `Pull` and `StreamingPull` requests
@@ -1086,9 +856,8 @@ public com.google.common.util.concurrent.ListenableFuture
*/
- public com.google.common.util.concurrent.ListenableFuture<
- com.google.pubsub.v1.DetachSubscriptionResponse>
- detachSubscription(com.google.pubsub.v1.DetachSubscriptionRequest request) {
+ public com.google.common.util.concurrent.ListenableFuture detachSubscription(
+ com.google.pubsub.v1.DetachSubscriptionRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getDetachSubscriptionMethod(), getCallOptions()), request);
}
@@ -1104,11 +873,11 @@ public com.google.common.util.concurrent.ListenableFuture
- implements io.grpc.stub.ServerCalls.UnaryMethod,
- io.grpc.stub.ServerCalls.ServerStreamingMethod,
- io.grpc.stub.ServerCalls.ClientStreamingMethod,
- io.grpc.stub.ServerCalls.BidiStreamingMethod {
+ private static final class MethodHandlers implements
+ io.grpc.stub.ServerCalls.UnaryMethod,
+ io.grpc.stub.ServerCalls.ServerStreamingMethod,
+ io.grpc.stub.ServerCalls.ClientStreamingMethod,
+ io.grpc.stub.ServerCalls.BidiStreamingMethod {
private final AsyncService serviceImpl;
private final int methodId;
@@ -1122,53 +891,40 @@ private static final class MethodHandlers
public void invoke(Req request, io.grpc.stub.StreamObserver responseObserver) {
switch (methodId) {
case METHODID_CREATE_TOPIC:
- serviceImpl.createTopic(
- (com.google.pubsub.v1.Topic) request,
+ serviceImpl.createTopic((com.google.pubsub.v1.Topic) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_UPDATE_TOPIC:
- serviceImpl.updateTopic(
- (com.google.pubsub.v1.UpdateTopicRequest) request,
+ serviceImpl.updateTopic((com.google.pubsub.v1.UpdateTopicRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_PUBLISH:
- serviceImpl.publish(
- (com.google.pubsub.v1.PublishRequest) request,
+ serviceImpl.publish((com.google.pubsub.v1.PublishRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_GET_TOPIC:
- serviceImpl.getTopic(
- (com.google.pubsub.v1.GetTopicRequest) request,
+ serviceImpl.getTopic((com.google.pubsub.v1.GetTopicRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_LIST_TOPICS:
- serviceImpl.listTopics(
- (com.google.pubsub.v1.ListTopicsRequest) request,
- (io.grpc.stub.StreamObserver)
- responseObserver);
+ serviceImpl.listTopics((com.google.pubsub.v1.ListTopicsRequest) request,
+ (io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_LIST_TOPIC_SUBSCRIPTIONS:
- serviceImpl.listTopicSubscriptions(
- (com.google.pubsub.v1.ListTopicSubscriptionsRequest) request,
- (io.grpc.stub.StreamObserver)
- responseObserver);
+ serviceImpl.listTopicSubscriptions((com.google.pubsub.v1.ListTopicSubscriptionsRequest) request,
+ (io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_LIST_TOPIC_SNAPSHOTS:
- serviceImpl.listTopicSnapshots(
- (com.google.pubsub.v1.ListTopicSnapshotsRequest) request,
- (io.grpc.stub.StreamObserver)
- responseObserver);
+ serviceImpl.listTopicSnapshots((com.google.pubsub.v1.ListTopicSnapshotsRequest) request,
+ (io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_DELETE_TOPIC:
- serviceImpl.deleteTopic(
- (com.google.pubsub.v1.DeleteTopicRequest) request,
+ serviceImpl.deleteTopic((com.google.pubsub.v1.DeleteTopicRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_DETACH_SUBSCRIPTION:
- serviceImpl.detachSubscription(
- (com.google.pubsub.v1.DetachSubscriptionRequest) request,
- (io.grpc.stub.StreamObserver)
- responseObserver);
+ serviceImpl.detachSubscription((com.google.pubsub.v1.DetachSubscriptionRequest) request,
+ (io.grpc.stub.StreamObserver) responseObserver);
break;
default:
throw new AssertionError();
@@ -1189,67 +945,73 @@ public io.grpc.stub.StreamObserver invoke(
public static final io.grpc.ServerServiceDefinition bindService(AsyncService service) {
return io.grpc.ServerServiceDefinition.builder(getServiceDescriptor())
.addMethod(
- getCreateTopicMethod(),
- io.grpc.stub.ServerCalls.asyncUnaryCall(
- new MethodHandlers(
- service, METHODID_CREATE_TOPIC)))
+ getCreateTopicMethod(),
+ io.grpc.stub.ServerCalls.asyncUnaryCall(
+ new MethodHandlers<
+ com.google.pubsub.v1.Topic,
+ com.google.pubsub.v1.Topic>(
+ service, METHODID_CREATE_TOPIC)))
.addMethod(
- getUpdateTopicMethod(),
- io.grpc.stub.ServerCalls.asyncUnaryCall(
- new MethodHandlers<
- com.google.pubsub.v1.UpdateTopicRequest, com.google.pubsub.v1.Topic>(
- service, METHODID_UPDATE_TOPIC)))
+ getUpdateTopicMethod(),
+ io.grpc.stub.ServerCalls.asyncUnaryCall(
+ new MethodHandlers<
+ com.google.pubsub.v1.UpdateTopicRequest,
+ com.google.pubsub.v1.Topic>(
+ service, METHODID_UPDATE_TOPIC)))
.addMethod(
- getPublishMethod(),
- io.grpc.stub.ServerCalls.asyncUnaryCall(
- new MethodHandlers<
- com.google.pubsub.v1.PublishRequest, com.google.pubsub.v1.PublishResponse>(
- service, METHODID_PUBLISH)))
+ getPublishMethod(),
+ io.grpc.stub.ServerCalls.asyncUnaryCall(
+ new MethodHandlers<
+ com.google.pubsub.v1.PublishRequest,
+ com.google.pubsub.v1.PublishResponse>(
+ service, METHODID_PUBLISH)))
.addMethod(
- getGetTopicMethod(),
- io.grpc.stub.ServerCalls.asyncUnaryCall(
- new MethodHandlers<
- com.google.pubsub.v1.GetTopicRequest, com.google.pubsub.v1.Topic>(
- service, METHODID_GET_TOPIC)))
+ getGetTopicMethod(),
+ io.grpc.stub.ServerCalls.asyncUnaryCall(
+ new MethodHandlers<
+ com.google.pubsub.v1.GetTopicRequest,
+ com.google.pubsub.v1.Topic>(
+ service, METHODID_GET_TOPIC)))
.addMethod(
- getListTopicsMethod(),
- io.grpc.stub.ServerCalls.asyncUnaryCall(
- new MethodHandlers<
- com.google.pubsub.v1.ListTopicsRequest,
- com.google.pubsub.v1.ListTopicsResponse>(service, METHODID_LIST_TOPICS)))
+ getListTopicsMethod(),
+ io.grpc.stub.ServerCalls.asyncUnaryCall(
+ new MethodHandlers<
+ com.google.pubsub.v1.ListTopicsRequest,
+ com.google.pubsub.v1.ListTopicsResponse>(
+ service, METHODID_LIST_TOPICS)))
.addMethod(
- getListTopicSubscriptionsMethod(),
- io.grpc.stub.ServerCalls.asyncUnaryCall(
- new MethodHandlers<
- com.google.pubsub.v1.ListTopicSubscriptionsRequest,
- com.google.pubsub.v1.ListTopicSubscriptionsResponse>(
- service, METHODID_LIST_TOPIC_SUBSCRIPTIONS)))
+ getListTopicSubscriptionsMethod(),
+ io.grpc.stub.ServerCalls.asyncUnaryCall(
+ new MethodHandlers<
+ com.google.pubsub.v1.ListTopicSubscriptionsRequest,
+ com.google.pubsub.v1.ListTopicSubscriptionsResponse>(
+ service, METHODID_LIST_TOPIC_SUBSCRIPTIONS)))
.addMethod(
- getListTopicSnapshotsMethod(),
- io.grpc.stub.ServerCalls.asyncUnaryCall(
- new MethodHandlers<
- com.google.pubsub.v1.ListTopicSnapshotsRequest,
- com.google.pubsub.v1.ListTopicSnapshotsResponse>(
- service, METHODID_LIST_TOPIC_SNAPSHOTS)))
+ getListTopicSnapshotsMethod(),
+ io.grpc.stub.ServerCalls.asyncUnaryCall(
+ new MethodHandlers<
+ com.google.pubsub.v1.ListTopicSnapshotsRequest,
+ com.google.pubsub.v1.ListTopicSnapshotsResponse>(
+ service, METHODID_LIST_TOPIC_SNAPSHOTS)))
.addMethod(
- getDeleteTopicMethod(),
- io.grpc.stub.ServerCalls.asyncUnaryCall(
- new MethodHandlers<
- com.google.pubsub.v1.DeleteTopicRequest, com.google.protobuf.Empty>(
- service, METHODID_DELETE_TOPIC)))
+ getDeleteTopicMethod(),
+ io.grpc.stub.ServerCalls.asyncUnaryCall(
+ new MethodHandlers<
+ com.google.pubsub.v1.DeleteTopicRequest,
+ com.google.protobuf.Empty>(
+ service, METHODID_DELETE_TOPIC)))
.addMethod(
- getDetachSubscriptionMethod(),
- io.grpc.stub.ServerCalls.asyncUnaryCall(
- new MethodHandlers<
- com.google.pubsub.v1.DetachSubscriptionRequest,
- com.google.pubsub.v1.DetachSubscriptionResponse>(
- service, METHODID_DETACH_SUBSCRIPTION)))
+ getDetachSubscriptionMethod(),
+ io.grpc.stub.ServerCalls.asyncUnaryCall(
+ new MethodHandlers<
+ com.google.pubsub.v1.DetachSubscriptionRequest,
+ com.google.pubsub.v1.DetachSubscriptionResponse>(
+ service, METHODID_DETACH_SUBSCRIPTION)))
.build();
}
- private abstract static class PublisherBaseDescriptorSupplier
- implements io.grpc.protobuf.ProtoFileDescriptorSupplier,
- io.grpc.protobuf.ProtoServiceDescriptorSupplier {
+ private static abstract class PublisherBaseDescriptorSupplier
+ implements io.grpc.protobuf.ProtoFileDescriptorSupplier, io.grpc.protobuf.ProtoServiceDescriptorSupplier {
PublisherBaseDescriptorSupplier() {}
@java.lang.Override
@@ -1291,20 +1053,18 @@ public static io.grpc.ServiceDescriptor getServiceDescriptor() {
synchronized (PublisherGrpc.class) {
result = serviceDescriptor;
if (result == null) {
- serviceDescriptor =
- result =
- io.grpc.ServiceDescriptor.newBuilder(SERVICE_NAME)
- .setSchemaDescriptor(new PublisherFileDescriptorSupplier())
- .addMethod(getCreateTopicMethod())
- .addMethod(getUpdateTopicMethod())
- .addMethod(getPublishMethod())
- .addMethod(getGetTopicMethod())
- .addMethod(getListTopicsMethod())
- .addMethod(getListTopicSubscriptionsMethod())
- .addMethod(getListTopicSnapshotsMethod())
- .addMethod(getDeleteTopicMethod())
- .addMethod(getDetachSubscriptionMethod())
- .build();
+ serviceDescriptor = result = io.grpc.ServiceDescriptor.newBuilder(SERVICE_NAME)
+ .setSchemaDescriptor(new PublisherFileDescriptorSupplier())
+ .addMethod(getCreateTopicMethod())
+ .addMethod(getUpdateTopicMethod())
+ .addMethod(getPublishMethod())
+ .addMethod(getGetTopicMethod())
+ .addMethod(getListTopicsMethod())
+ .addMethod(getListTopicSubscriptionsMethod())
+ .addMethod(getListTopicSnapshotsMethod())
+ .addMethod(getDeleteTopicMethod())
+ .addMethod(getDetachSubscriptionMethod())
+ .build();
}
}
}
diff --git a/owl-bot-staging/v1/grpc-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/SchemaServiceGrpc.java b/owl-bot-staging/v1/grpc-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/SchemaServiceGrpc.java
new file mode 100644
index 000000000..331f67936
--- /dev/null
+++ b/owl-bot-staging/v1/grpc-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/SchemaServiceGrpc.java
@@ -0,0 +1,1097 @@
+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")
+@io.grpc.stub.annotations.GrpcGenerated
+public final class SchemaServiceGrpc {
+
+ private SchemaServiceGrpc() {}
+
+ public static final java.lang.String SERVICE_NAME = "google.pubsub.v1.SchemaService";
+
+ // Static method descriptors that strictly reflect the proto.
+ private static volatile io.grpc.MethodDescriptor 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 getCreateSchemaMethod() {
+ io.grpc.MethodDescriptor getCreateSchemaMethod;
+ if ((getCreateSchemaMethod = SchemaServiceGrpc.getCreateSchemaMethod) == null) {
+ synchronized (SchemaServiceGrpc.class) {
+ if ((getCreateSchemaMethod = SchemaServiceGrpc.getCreateSchemaMethod) == null) {
+ SchemaServiceGrpc.getCreateSchemaMethod = getCreateSchemaMethod =
+ io.grpc.MethodDescriptor.newBuilder()
+ .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName(generateFullMethodName(SERVICE_NAME, "CreateSchema"))
+ .setSampledToLocalTracing(true)
+ .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.pubsub.v1.CreateSchemaRequest.getDefaultInstance()))
+ .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.pubsub.v1.Schema.getDefaultInstance()))
+ .setSchemaDescriptor(new SchemaServiceMethodDescriptorSupplier("CreateSchema"))
+ .build();
+ }
+ }
+ }
+ return getCreateSchemaMethod;
+ }
+
+ private static volatile io.grpc.MethodDescriptor getGetSchemaMethod;
+
+ @io.grpc.stub.annotations.RpcMethod(
+ fullMethodName = SERVICE_NAME + '/' + "GetSchema",
+ requestType = com.google.pubsub.v1.GetSchemaRequest.class,
+ responseType = com.google.pubsub.v1.Schema.class,
+ methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
+ public static io.grpc.MethodDescriptor getGetSchemaMethod() {
+ io.grpc.MethodDescriptor getGetSchemaMethod;
+ if ((getGetSchemaMethod = SchemaServiceGrpc.getGetSchemaMethod) == null) {
+ synchronized (SchemaServiceGrpc.class) {
+ if ((getGetSchemaMethod = SchemaServiceGrpc.getGetSchemaMethod) == null) {
+ SchemaServiceGrpc.getGetSchemaMethod = getGetSchemaMethod =
+ io.grpc.MethodDescriptor.newBuilder()
+ .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName(generateFullMethodName(SERVICE_NAME, "GetSchema"))
+ .setSampledToLocalTracing(true)
+ .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.pubsub.v1.GetSchemaRequest.getDefaultInstance()))
+ .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.pubsub.v1.Schema.getDefaultInstance()))
+ .setSchemaDescriptor(new SchemaServiceMethodDescriptorSupplier("GetSchema"))
+ .build();
+ }
+ }
+ }
+ return getGetSchemaMethod;
+ }
+
+ private static volatile io.grpc.MethodDescriptor getListSchemasMethod;
+
+ @io.grpc.stub.annotations.RpcMethod(
+ fullMethodName = SERVICE_NAME + '/' + "ListSchemas",
+ requestType = com.google.pubsub.v1.ListSchemasRequest.class,
+ responseType = com.google.pubsub.v1.ListSchemasResponse.class,
+ methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
+ public static io.grpc.MethodDescriptor getListSchemasMethod() {
+ io.grpc.MethodDescriptor getListSchemasMethod;
+ if ((getListSchemasMethod = SchemaServiceGrpc.getListSchemasMethod) == null) {
+ synchronized (SchemaServiceGrpc.class) {
+ if ((getListSchemasMethod = SchemaServiceGrpc.getListSchemasMethod) == null) {
+ SchemaServiceGrpc.getListSchemasMethod = getListSchemasMethod =
+ io.grpc.MethodDescriptor.newBuilder()
+ .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName(generateFullMethodName(SERVICE_NAME, "ListSchemas"))
+ .setSampledToLocalTracing(true)
+ .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.pubsub.v1.ListSchemasRequest.getDefaultInstance()))
+ .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.pubsub.v1.ListSchemasResponse.getDefaultInstance()))
+ .setSchemaDescriptor(new SchemaServiceMethodDescriptorSupplier("ListSchemas"))
+ .build();
+ }
+ }
+ }
+ return getListSchemasMethod;
+ }
+
+ private static volatile io.grpc.MethodDescriptor getListSchemaRevisionsMethod;
+
+ @io.grpc.stub.annotations.RpcMethod(
+ fullMethodName = SERVICE_NAME + '/' + "ListSchemaRevisions",
+ requestType = com.google.pubsub.v1.ListSchemaRevisionsRequest.class,
+ responseType = com.google.pubsub.v1.ListSchemaRevisionsResponse.class,
+ methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
+ public static io.grpc.MethodDescriptor getListSchemaRevisionsMethod() {
+ io.grpc.MethodDescriptor getListSchemaRevisionsMethod;
+ if ((getListSchemaRevisionsMethod = SchemaServiceGrpc.getListSchemaRevisionsMethod) == null) {
+ synchronized (SchemaServiceGrpc.class) {
+ if ((getListSchemaRevisionsMethod = SchemaServiceGrpc.getListSchemaRevisionsMethod) == null) {
+ SchemaServiceGrpc.getListSchemaRevisionsMethod = getListSchemaRevisionsMethod =
+ io.grpc.MethodDescriptor.newBuilder()
+ .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName(generateFullMethodName(SERVICE_NAME, "ListSchemaRevisions"))
+ .setSampledToLocalTracing(true)
+ .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.pubsub.v1.ListSchemaRevisionsRequest.getDefaultInstance()))
+ .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.pubsub.v1.ListSchemaRevisionsResponse.getDefaultInstance()))
+ .setSchemaDescriptor(new SchemaServiceMethodDescriptorSupplier("ListSchemaRevisions"))
+ .build();
+ }
+ }
+ }
+ return getListSchemaRevisionsMethod;
+ }
+
+ private static volatile io.grpc.MethodDescriptor getCommitSchemaMethod;
+
+ @io.grpc.stub.annotations.RpcMethod(
+ fullMethodName = SERVICE_NAME + '/' + "CommitSchema",
+ requestType = com.google.pubsub.v1.CommitSchemaRequest.class,
+ responseType = com.google.pubsub.v1.Schema.class,
+ methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
+ public static io.grpc.MethodDescriptor getCommitSchemaMethod() {
+ io.grpc.MethodDescriptor getCommitSchemaMethod;
+ if ((getCommitSchemaMethod = SchemaServiceGrpc.getCommitSchemaMethod) == null) {
+ synchronized (SchemaServiceGrpc.class) {
+ if ((getCommitSchemaMethod = SchemaServiceGrpc.getCommitSchemaMethod) == null) {
+ SchemaServiceGrpc.getCommitSchemaMethod = getCommitSchemaMethod =
+ io.grpc.MethodDescriptor.newBuilder()
+ .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName(generateFullMethodName(SERVICE_NAME, "CommitSchema"))
+ .setSampledToLocalTracing(true)
+ .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.pubsub.v1.CommitSchemaRequest.getDefaultInstance()))
+ .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.pubsub.v1.Schema.getDefaultInstance()))
+ .setSchemaDescriptor(new SchemaServiceMethodDescriptorSupplier("CommitSchema"))
+ .build();
+ }
+ }
+ }
+ return getCommitSchemaMethod;
+ }
+
+ private static volatile io.grpc.MethodDescriptor getRollbackSchemaMethod;
+
+ @io.grpc.stub.annotations.RpcMethod(
+ fullMethodName = SERVICE_NAME + '/' + "RollbackSchema",
+ requestType = com.google.pubsub.v1.RollbackSchemaRequest.class,
+ responseType = com.google.pubsub.v1.Schema.class,
+ methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
+ public static io.grpc.MethodDescriptor getRollbackSchemaMethod() {
+ io.grpc.MethodDescriptor getRollbackSchemaMethod;
+ if ((getRollbackSchemaMethod = SchemaServiceGrpc.getRollbackSchemaMethod) == null) {
+ synchronized (SchemaServiceGrpc.class) {
+ if ((getRollbackSchemaMethod = SchemaServiceGrpc.getRollbackSchemaMethod) == null) {
+ SchemaServiceGrpc.getRollbackSchemaMethod = getRollbackSchemaMethod =
+ io.grpc.MethodDescriptor.newBuilder()
+ .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName(generateFullMethodName(SERVICE_NAME, "RollbackSchema"))
+ .setSampledToLocalTracing(true)
+ .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.pubsub.v1.RollbackSchemaRequest.getDefaultInstance()))
+ .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.pubsub.v1.Schema.getDefaultInstance()))
+ .setSchemaDescriptor(new SchemaServiceMethodDescriptorSupplier("RollbackSchema"))
+ .build();
+ }
+ }
+ }
+ return getRollbackSchemaMethod;
+ }
+
+ private static volatile io.grpc.MethodDescriptor getDeleteSchemaRevisionMethod;
+
+ @io.grpc.stub.annotations.RpcMethod(
+ fullMethodName = SERVICE_NAME + '/' + "DeleteSchemaRevision",
+ requestType = com.google.pubsub.v1.DeleteSchemaRevisionRequest.class,
+ responseType = com.google.pubsub.v1.Schema.class,
+ methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
+ public static io.grpc.MethodDescriptor getDeleteSchemaRevisionMethod() {
+ io.grpc.MethodDescriptor getDeleteSchemaRevisionMethod;
+ if ((getDeleteSchemaRevisionMethod = SchemaServiceGrpc.getDeleteSchemaRevisionMethod) == null) {
+ synchronized (SchemaServiceGrpc.class) {
+ if ((getDeleteSchemaRevisionMethod = SchemaServiceGrpc.getDeleteSchemaRevisionMethod) == null) {
+ SchemaServiceGrpc.getDeleteSchemaRevisionMethod = getDeleteSchemaRevisionMethod =
+ io.grpc.MethodDescriptor.newBuilder()
+ .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName(generateFullMethodName(SERVICE_NAME, "DeleteSchemaRevision"))
+ .setSampledToLocalTracing(true)
+ .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.pubsub.v1.DeleteSchemaRevisionRequest.getDefaultInstance()))
+ .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.pubsub.v1.Schema.getDefaultInstance()))
+ .setSchemaDescriptor(new SchemaServiceMethodDescriptorSupplier("DeleteSchemaRevision"))
+ .build();
+ }
+ }
+ }
+ return getDeleteSchemaRevisionMethod;
+ }
+
+ private static volatile io.grpc.MethodDescriptor getDeleteSchemaMethod;
+
+ @io.grpc.stub.annotations.RpcMethod(
+ fullMethodName = SERVICE_NAME + '/' + "DeleteSchema",
+ requestType = com.google.pubsub.v1.DeleteSchemaRequest.class,
+ responseType = com.google.protobuf.Empty.class,
+ methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
+ public static io.grpc.MethodDescriptor getDeleteSchemaMethod() {
+ io.grpc.MethodDescriptor getDeleteSchemaMethod;
+ if ((getDeleteSchemaMethod = SchemaServiceGrpc.getDeleteSchemaMethod) == null) {
+ synchronized (SchemaServiceGrpc.class) {
+ if ((getDeleteSchemaMethod = SchemaServiceGrpc.getDeleteSchemaMethod) == null) {
+ SchemaServiceGrpc.getDeleteSchemaMethod = getDeleteSchemaMethod =
+ io.grpc.MethodDescriptor.newBuilder()
+ .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName(generateFullMethodName(SERVICE_NAME, "DeleteSchema"))
+ .setSampledToLocalTracing(true)
+ .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.pubsub.v1.DeleteSchemaRequest.getDefaultInstance()))
+ .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.protobuf.Empty.getDefaultInstance()))
+ .setSchemaDescriptor(new SchemaServiceMethodDescriptorSupplier("DeleteSchema"))
+ .build();
+ }
+ }
+ }
+ return getDeleteSchemaMethod;
+ }
+
+ private static volatile io.grpc.MethodDescriptor getValidateSchemaMethod;
+
+ @io.grpc.stub.annotations.RpcMethod(
+ fullMethodName = SERVICE_NAME + '/' + "ValidateSchema",
+ requestType = com.google.pubsub.v1.ValidateSchemaRequest.class,
+ responseType = com.google.pubsub.v1.ValidateSchemaResponse.class,
+ methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
+ public static io.grpc.MethodDescriptor getValidateSchemaMethod() {
+ io.grpc.MethodDescriptor getValidateSchemaMethod;
+ if ((getValidateSchemaMethod = SchemaServiceGrpc.getValidateSchemaMethod) == null) {
+ synchronized (SchemaServiceGrpc.class) {
+ if ((getValidateSchemaMethod = SchemaServiceGrpc.getValidateSchemaMethod) == null) {
+ SchemaServiceGrpc.getValidateSchemaMethod = getValidateSchemaMethod =
+ io.grpc.MethodDescriptor.newBuilder()
+ .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName(generateFullMethodName(SERVICE_NAME, "ValidateSchema"))
+ .setSampledToLocalTracing(true)
+ .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.pubsub.v1.ValidateSchemaRequest.getDefaultInstance()))
+ .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.pubsub.v1.ValidateSchemaResponse.getDefaultInstance()))
+ .setSchemaDescriptor(new SchemaServiceMethodDescriptorSupplier("ValidateSchema"))
+ .build();
+ }
+ }
+ }
+ return getValidateSchemaMethod;
+ }
+
+ private static volatile io.grpc.MethodDescriptor getValidateMessageMethod;
+
+ @io.grpc.stub.annotations.RpcMethod(
+ fullMethodName = SERVICE_NAME + '/' + "ValidateMessage",
+ requestType = com.google.pubsub.v1.ValidateMessageRequest.class,
+ responseType = com.google.pubsub.v1.ValidateMessageResponse.class,
+ methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
+ public static io.grpc.MethodDescriptor getValidateMessageMethod() {
+ io.grpc.MethodDescriptor getValidateMessageMethod;
+ if ((getValidateMessageMethod = SchemaServiceGrpc.getValidateMessageMethod) == null) {
+ synchronized (SchemaServiceGrpc.class) {
+ if ((getValidateMessageMethod = SchemaServiceGrpc.getValidateMessageMethod) == null) {
+ SchemaServiceGrpc.getValidateMessageMethod = getValidateMessageMethod =
+ io.grpc.MethodDescriptor.newBuilder()
+ .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName(generateFullMethodName(SERVICE_NAME, "ValidateMessage"))
+ .setSampledToLocalTracing(true)
+ .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.pubsub.v1.ValidateMessageRequest.getDefaultInstance()))
+ .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.pubsub.v1.ValidateMessageResponse.getDefaultInstance()))
+ .setSchemaDescriptor(new SchemaServiceMethodDescriptorSupplier("ValidateMessage"))
+ .build();
+ }
+ }
+ }
+ return getValidateMessageMethod;
+ }
+
+ /**
+ * Creates a new async stub that supports all call types for the service
+ */
+ public static SchemaServiceStub newStub(io.grpc.Channel channel) {
+ io.grpc.stub.AbstractStub.StubFactory factory =
+ new io.grpc.stub.AbstractStub.StubFactory() {
+ @java.lang.Override
+ public SchemaServiceStub newStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
+ return new SchemaServiceStub(channel, callOptions);
+ }
+ };
+ return SchemaServiceStub.newStub(factory, channel);
+ }
+
+ /**
+ * Creates a new blocking-style stub that supports unary and streaming output calls on the service
+ */
+ public static SchemaServiceBlockingStub newBlockingStub(
+ io.grpc.Channel channel) {
+ io.grpc.stub.AbstractStub.StubFactory factory =
+ new io.grpc.stub.AbstractStub.StubFactory