diff --git a/.github/workflows/hermetic_library_generation.yaml b/.github/workflows/hermetic_library_generation.yaml index 7023350ad..f61e4eb85 100644 --- a/.github/workflows/hermetic_library_generation.yaml +++ b/.github/workflows/hermetic_library_generation.yaml @@ -37,7 +37,7 @@ jobs: with: fetch-depth: 0 token: ${{ secrets.CLOUD_JAVA_BOT_TOKEN }} - - uses: googleapis/sdk-platform-java/.github/scripts@v2.63.0 + - uses: googleapis/sdk-platform-java/.github/scripts@v2.64.1 if: env.SHOULD_RUN == 'true' with: base_ref: ${{ github.base_ref }} diff --git a/.github/workflows/update_generation_config.yaml b/.github/workflows/update_generation_config.yaml index 59e39834d..a7e14bb48 100644 --- a/.github/workflows/update_generation_config.yaml +++ b/.github/workflows/update_generation_config.yaml @@ -26,7 +26,7 @@ jobs: # the branch into which the pull request is merged base_branch: main steps: - - uses: actions/checkout@v5 + - uses: actions/checkout@v4 with: fetch-depth: 0 token: ${{ secrets.CLOUD_JAVA_BOT_TOKEN }} diff --git a/.kokoro/presubmit/graalvm-native-a.cfg b/.kokoro/presubmit/graalvm-native-a.cfg index 55c5543e2..b772eac66 100644 --- a/.kokoro/presubmit/graalvm-native-a.cfg +++ b/.kokoro/presubmit/graalvm-native-a.cfg @@ -3,7 +3,7 @@ # Configure the docker image for kokoro-trampoline. env_vars: { key: "TRAMPOLINE_IMAGE" - value: "gcr.io/cloud-devrel-public-resources/graalvm_sdk_platform_a:3.53.0" # {x-version-update:google-cloud-shared-dependencies:current} + value: "gcr.io/cloud-devrel-public-resources/graalvm_sdk_platform_a:3.54.1" # {x-version-update:google-cloud-shared-dependencies:current} } env_vars: { diff --git a/.kokoro/presubmit/graalvm-native-b.cfg b/.kokoro/presubmit/graalvm-native-b.cfg index 5c981b984..baf136cf8 100644 --- a/.kokoro/presubmit/graalvm-native-b.cfg +++ b/.kokoro/presubmit/graalvm-native-b.cfg @@ -3,7 +3,7 @@ # Configure the docker image for kokoro-trampoline. env_vars: { key: "TRAMPOLINE_IMAGE" - value: "gcr.io/cloud-devrel-public-resources/graalvm_sdk_platform_b:3.53.0" # {x-version-update:google-cloud-shared-dependencies:current} + value: "gcr.io/cloud-devrel-public-resources/graalvm_sdk_platform_b:3.54.1" # {x-version-update:google-cloud-shared-dependencies:current} } env_vars: { diff --git a/.kokoro/presubmit/graalvm-native-c.cfg b/.kokoro/presubmit/graalvm-native-c.cfg index f2032499d..2fb2fc87c 100644 --- a/.kokoro/presubmit/graalvm-native-c.cfg +++ b/.kokoro/presubmit/graalvm-native-c.cfg @@ -3,7 +3,7 @@ # Configure the docker image for kokoro-trampoline. env_vars: { key: "TRAMPOLINE_IMAGE" - value: "gcr.io/cloud-devrel-public-resources/graalvm_sdk_platform_c:3.53.0" # {x-version-update:google-cloud-shared-dependencies:current} + value: "gcr.io/cloud-devrel-public-resources/graalvm_sdk_platform_c:3.54.1" # {x-version-update:google-cloud-shared-dependencies:current} } env_vars: { diff --git a/README.md b/README.md index 6f8ac9068..f0b5c24b3 100644 --- a/README.md +++ b/README.md @@ -19,7 +19,7 @@ If you are using Maven with [BOM][libraries-bom], add this to your pom.xml file: com.google.cloud libraries-bom - 26.70.0 + 26.71.0 pom import @@ -43,7 +43,7 @@ If you are using Maven without the BOM, add this to your dependencies: com.google.cloud google-cloud-pubsub - 1.142.0 + 1.143.0 ``` diff --git a/generation_config.yaml b/generation_config.yaml index 626e36d32..744688ac1 100644 --- a/generation_config.yaml +++ b/generation_config.yaml @@ -1,5 +1,5 @@ -gapic_generator_version: 2.63.0 -googleapis_commitish: b1a9eefc2e1021fb9465bdac5e2984499451ae34 +gapic_generator_version: 2.64.1 +googleapis_commitish: 5342712986262b93211b136eb4bd6fb79b3764af libraries_bom_version: 26.71.0 libraries: - api_shortname: pubsub diff --git a/grpc-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/PublisherGrpc.java b/grpc-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/PublisherGrpc.java index a1b0a2b1c..8ee09f14e 100644 --- a/grpc-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/PublisherGrpc.java +++ b/grpc-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/PublisherGrpc.java @@ -25,9 +25,6 @@ * messages to a topic. * */ -@javax.annotation.Generated( - value = "by gRPC proto compiler", - comments = "Source: google/pubsub/v1/pubsub.proto") @io.grpc.stub.annotations.GrpcGenerated public final class PublisherGrpc { @@ -832,8 +829,9 @@ protected PublisherBlockingV2Stub build( * (https://cloud.google.com/pubsub/docs/pubsub-basics#resource_names). * */ - public com.google.pubsub.v1.Topic createTopic(com.google.pubsub.v1.Topic request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + public com.google.pubsub.v1.Topic createTopic(com.google.pubsub.v1.Topic request) + throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getCreateTopicMethod(), getCallOptions(), request); } @@ -845,8 +843,9 @@ public com.google.pubsub.v1.Topic createTopic(com.google.pubsub.v1.Topic request * mask. Note that certain properties of a topic are not modifiable. * */ - public com.google.pubsub.v1.Topic updateTopic(com.google.pubsub.v1.UpdateTopicRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + public com.google.pubsub.v1.Topic updateTopic(com.google.pubsub.v1.UpdateTopicRequest request) + throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getUpdateTopicMethod(), getCallOptions(), request); } @@ -858,9 +857,9 @@ public com.google.pubsub.v1.Topic updateTopic(com.google.pubsub.v1.UpdateTopicRe * does not exist. * */ - public com.google.pubsub.v1.PublishResponse publish( - com.google.pubsub.v1.PublishRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + public com.google.pubsub.v1.PublishResponse publish(com.google.pubsub.v1.PublishRequest request) + throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getPublishMethod(), getCallOptions(), request); } @@ -871,8 +870,9 @@ public com.google.pubsub.v1.PublishResponse publish( * Gets the configuration of a topic. * */ - public com.google.pubsub.v1.Topic getTopic(com.google.pubsub.v1.GetTopicRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + public com.google.pubsub.v1.Topic getTopic(com.google.pubsub.v1.GetTopicRequest request) + throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getGetTopicMethod(), getCallOptions(), request); } @@ -884,8 +884,8 @@ public com.google.pubsub.v1.Topic getTopic(com.google.pubsub.v1.GetTopicRequest * */ public com.google.pubsub.v1.ListTopicsResponse listTopics( - com.google.pubsub.v1.ListTopicsRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.pubsub.v1.ListTopicsRequest request) throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getListTopicsMethod(), getCallOptions(), request); } @@ -897,8 +897,8 @@ public com.google.pubsub.v1.ListTopicsResponse listTopics( * */ public com.google.pubsub.v1.ListTopicSubscriptionsResponse listTopicSubscriptions( - com.google.pubsub.v1.ListTopicSubscriptionsRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.pubsub.v1.ListTopicSubscriptionsRequest request) throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getListTopicSubscriptionsMethod(), getCallOptions(), request); } @@ -914,8 +914,8 @@ public com.google.pubsub.v1.ListTopicSubscriptionsResponse listTopicSubscription * */ public com.google.pubsub.v1.ListTopicSnapshotsResponse listTopicSnapshots( - com.google.pubsub.v1.ListTopicSnapshotsRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.pubsub.v1.ListTopicSnapshotsRequest request) throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getListTopicSnapshotsMethod(), getCallOptions(), request); } @@ -930,8 +930,9 @@ public com.google.pubsub.v1.ListTopicSnapshotsResponse listTopicSnapshots( * not deleted, but their `topic` field is set to `_deleted-topic_`. * */ - public com.google.protobuf.Empty deleteTopic(com.google.pubsub.v1.DeleteTopicRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + public com.google.protobuf.Empty deleteTopic(com.google.pubsub.v1.DeleteTopicRequest request) + throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getDeleteTopicMethod(), getCallOptions(), request); } @@ -946,8 +947,8 @@ public com.google.protobuf.Empty deleteTopic(com.google.pubsub.v1.DeleteTopicReq * */ public com.google.pubsub.v1.DetachSubscriptionResponse detachSubscription( - com.google.pubsub.v1.DetachSubscriptionRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.pubsub.v1.DetachSubscriptionRequest request) throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getDetachSubscriptionMethod(), getCallOptions(), request); } } 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 index 35c281c88..59fbec01b 100644 --- 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 @@ -24,9 +24,6 @@ * 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 { @@ -881,8 +878,8 @@ protected SchemaServiceBlockingV2Stub build( * */ public com.google.pubsub.v1.Schema createSchema( - com.google.pubsub.v1.CreateSchemaRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.pubsub.v1.CreateSchemaRequest request) throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getCreateSchemaMethod(), getCallOptions(), request); } @@ -893,8 +890,9 @@ public com.google.pubsub.v1.Schema createSchema( * Gets a schema. * */ - public com.google.pubsub.v1.Schema getSchema(com.google.pubsub.v1.GetSchemaRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + public com.google.pubsub.v1.Schema getSchema(com.google.pubsub.v1.GetSchemaRequest request) + throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getGetSchemaMethod(), getCallOptions(), request); } @@ -906,8 +904,8 @@ public com.google.pubsub.v1.Schema getSchema(com.google.pubsub.v1.GetSchemaReque * */ public com.google.pubsub.v1.ListSchemasResponse listSchemas( - com.google.pubsub.v1.ListSchemasRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.pubsub.v1.ListSchemasRequest request) throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getListSchemasMethod(), getCallOptions(), request); } @@ -919,8 +917,8 @@ public com.google.pubsub.v1.ListSchemasResponse listSchemas( * */ public com.google.pubsub.v1.ListSchemaRevisionsResponse listSchemaRevisions( - com.google.pubsub.v1.ListSchemaRevisionsRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.pubsub.v1.ListSchemaRevisionsRequest request) throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getListSchemaRevisionsMethod(), getCallOptions(), request); } @@ -932,8 +930,8 @@ public com.google.pubsub.v1.ListSchemaRevisionsResponse listSchemaRevisions( * */ public com.google.pubsub.v1.Schema commitSchema( - com.google.pubsub.v1.CommitSchemaRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.pubsub.v1.CommitSchemaRequest request) throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getCommitSchemaMethod(), getCallOptions(), request); } @@ -945,8 +943,8 @@ public com.google.pubsub.v1.Schema commitSchema( * */ public com.google.pubsub.v1.Schema rollbackSchema( - com.google.pubsub.v1.RollbackSchemaRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.pubsub.v1.RollbackSchemaRequest request) throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getRollbackSchemaMethod(), getCallOptions(), request); } @@ -958,8 +956,8 @@ public com.google.pubsub.v1.Schema rollbackSchema( * */ public com.google.pubsub.v1.Schema deleteSchemaRevision( - com.google.pubsub.v1.DeleteSchemaRevisionRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.pubsub.v1.DeleteSchemaRevisionRequest request) throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getDeleteSchemaRevisionMethod(), getCallOptions(), request); } @@ -970,9 +968,9 @@ public com.google.pubsub.v1.Schema deleteSchemaRevision( * Deletes a schema. * */ - public com.google.protobuf.Empty deleteSchema( - com.google.pubsub.v1.DeleteSchemaRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + public com.google.protobuf.Empty deleteSchema(com.google.pubsub.v1.DeleteSchemaRequest request) + throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getDeleteSchemaMethod(), getCallOptions(), request); } @@ -984,8 +982,8 @@ public com.google.protobuf.Empty deleteSchema( * */ public com.google.pubsub.v1.ValidateSchemaResponse validateSchema( - com.google.pubsub.v1.ValidateSchemaRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.pubsub.v1.ValidateSchemaRequest request) throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getValidateSchemaMethod(), getCallOptions(), request); } @@ -997,8 +995,8 @@ public com.google.pubsub.v1.ValidateSchemaResponse validateSchema( * */ public com.google.pubsub.v1.ValidateMessageResponse validateMessage( - com.google.pubsub.v1.ValidateMessageRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.pubsub.v1.ValidateMessageRequest request) throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getValidateMessageMethod(), getCallOptions(), request); } } diff --git a/grpc-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/SubscriberGrpc.java b/grpc-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/SubscriberGrpc.java index 2a8fc9299..26003fb0e 100644 --- a/grpc-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/SubscriberGrpc.java +++ b/grpc-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/SubscriberGrpc.java @@ -26,9 +26,6 @@ * establishing a bi-directional stream using the `StreamingPull` method. * */ -@javax.annotation.Generated( - value = "by gRPC proto compiler", - comments = "Source: google/pubsub/v1/pubsub.proto") @io.grpc.stub.annotations.GrpcGenerated public final class SubscriberGrpc { @@ -1450,8 +1447,8 @@ protected SubscriberBlockingV2Stub build( * */ public com.google.pubsub.v1.Subscription createSubscription( - com.google.pubsub.v1.Subscription request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.pubsub.v1.Subscription request) throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getCreateSubscriptionMethod(), getCallOptions(), request); } @@ -1463,8 +1460,8 @@ public com.google.pubsub.v1.Subscription createSubscription( * */ public com.google.pubsub.v1.Subscription getSubscription( - com.google.pubsub.v1.GetSubscriptionRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.pubsub.v1.GetSubscriptionRequest request) throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getGetSubscriptionMethod(), getCallOptions(), request); } @@ -1478,8 +1475,8 @@ public com.google.pubsub.v1.Subscription getSubscription( * */ public com.google.pubsub.v1.Subscription updateSubscription( - com.google.pubsub.v1.UpdateSubscriptionRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.pubsub.v1.UpdateSubscriptionRequest request) throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getUpdateSubscriptionMethod(), getCallOptions(), request); } @@ -1491,8 +1488,8 @@ public com.google.pubsub.v1.Subscription updateSubscription( * */ public com.google.pubsub.v1.ListSubscriptionsResponse listSubscriptions( - com.google.pubsub.v1.ListSubscriptionsRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.pubsub.v1.ListSubscriptionsRequest request) throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getListSubscriptionsMethod(), getCallOptions(), request); } @@ -1508,8 +1505,8 @@ public com.google.pubsub.v1.ListSubscriptionsResponse listSubscriptions( * */ public com.google.protobuf.Empty deleteSubscription( - com.google.pubsub.v1.DeleteSubscriptionRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.pubsub.v1.DeleteSubscriptionRequest request) throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getDeleteSubscriptionMethod(), getCallOptions(), request); } @@ -1525,8 +1522,8 @@ public com.google.protobuf.Empty deleteSubscription( * */ public com.google.protobuf.Empty modifyAckDeadline( - com.google.pubsub.v1.ModifyAckDeadlineRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.pubsub.v1.ModifyAckDeadlineRequest request) throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getModifyAckDeadlineMethod(), getCallOptions(), request); } @@ -1542,8 +1539,9 @@ public com.google.protobuf.Empty modifyAckDeadline( * than once will not result in an error. * */ - public com.google.protobuf.Empty acknowledge(com.google.pubsub.v1.AcknowledgeRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + public com.google.protobuf.Empty acknowledge(com.google.pubsub.v1.AcknowledgeRequest request) + throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getAcknowledgeMethod(), getCallOptions(), request); } @@ -1554,8 +1552,9 @@ public com.google.protobuf.Empty acknowledge(com.google.pubsub.v1.AcknowledgeReq * Pulls messages from the server. * */ - public com.google.pubsub.v1.PullResponse pull(com.google.pubsub.v1.PullRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + public com.google.pubsub.v1.PullResponse pull(com.google.pubsub.v1.PullRequest request) + throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getPullMethod(), getCallOptions(), request); } @@ -1592,8 +1591,8 @@ public com.google.pubsub.v1.PullResponse pull(com.google.pubsub.v1.PullRequest r * */ public com.google.protobuf.Empty modifyPushConfig( - com.google.pubsub.v1.ModifyPushConfigRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.pubsub.v1.ModifyPushConfigRequest request) throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getModifyPushConfigMethod(), getCallOptions(), request); } @@ -1609,8 +1608,8 @@ public com.google.protobuf.Empty modifyPushConfig( * */ public com.google.pubsub.v1.Snapshot getSnapshot( - com.google.pubsub.v1.GetSnapshotRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.pubsub.v1.GetSnapshotRequest request) throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getGetSnapshotMethod(), getCallOptions(), request); } @@ -1626,8 +1625,8 @@ public com.google.pubsub.v1.Snapshot getSnapshot( * */ public com.google.pubsub.v1.ListSnapshotsResponse listSnapshots( - com.google.pubsub.v1.ListSnapshotsRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.pubsub.v1.ListSnapshotsRequest request) throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getListSnapshotsMethod(), getCallOptions(), request); } @@ -1654,8 +1653,8 @@ public com.google.pubsub.v1.ListSnapshotsResponse listSnapshots( * */ public com.google.pubsub.v1.Snapshot createSnapshot( - com.google.pubsub.v1.CreateSnapshotRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.pubsub.v1.CreateSnapshotRequest request) throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getCreateSnapshotMethod(), getCallOptions(), request); } @@ -1672,8 +1671,8 @@ public com.google.pubsub.v1.Snapshot createSnapshot( * */ public com.google.pubsub.v1.Snapshot updateSnapshot( - com.google.pubsub.v1.UpdateSnapshotRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.pubsub.v1.UpdateSnapshotRequest request) throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getUpdateSnapshotMethod(), getCallOptions(), request); } @@ -1693,8 +1692,8 @@ public com.google.pubsub.v1.Snapshot updateSnapshot( * */ public com.google.protobuf.Empty deleteSnapshot( - com.google.pubsub.v1.DeleteSnapshotRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + com.google.pubsub.v1.DeleteSnapshotRequest request) throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getDeleteSnapshotMethod(), getCallOptions(), request); } @@ -1711,8 +1710,9 @@ public com.google.protobuf.Empty deleteSnapshot( * snapshot must be on the same topic. * */ - public com.google.pubsub.v1.SeekResponse seek(com.google.pubsub.v1.SeekRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( + public com.google.pubsub.v1.SeekResponse seek(com.google.pubsub.v1.SeekRequest request) + throws io.grpc.StatusException { + return io.grpc.stub.ClientCalls.blockingV2UnaryCall( getChannel(), getSeekMethod(), getCallOptions(), request); } }