From befaf180d5ab43c46e6fc13e144c7495074daa4f Mon Sep 17 00:00:00 2001 From: cloud-java-bot Date: Tue, 30 Sep 2025 02:29:49 +0000 Subject: [PATCH 1/6] chore: Update generation configuration at Tue Sep 30 02:29:43 UTC 2025 --- generation_config.yaml | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/generation_config.yaml b/generation_config.yaml index 7743a7af9..80fe2e371 100644 --- a/generation_config.yaml +++ b/generation_config.yaml @@ -1,6 +1,6 @@ gapic_generator_version: 2.62.2 -googleapis_commitish: 31b413bc4feb03f6849c718048c2b9998561b5fa -libraries_bom_version: 26.68.0 +googleapis_commitish: eab82ec804dfd76372ca369910ccd0766ee02e5c +libraries_bom_version: 26.69.0 libraries: - api_shortname: pubsub name_pretty: Cloud Pub/Sub From 4adc8a5ae93f75c6c9039244e30eddbaf6160fd0 Mon Sep 17 00:00:00 2001 From: cloud-java-bot Date: Tue, 30 Sep 2025 02:32:21 +0000 Subject: [PATCH 2/6] chore: generate libraries at Tue Sep 30 02:30:17 UTC 2025 --- .../workflows/update_generation_config.yaml | 2 +- README.md | 4 +- .../pubsub/v1/SubscriptionAdminClient.java | 1 + .../v1/SubscriptionAdminClientTest.java | 2 + .../com/google/pubsub/v1/PubsubProto.java | 285 +++++++++--------- .../pubsub/v1/StreamingPullRequest.java | 105 +++++++ .../v1/StreamingPullRequestOrBuilder.java | 15 + .../main/proto/google/pubsub/v1/pubsub.proto | 5 + 8 files changed, 274 insertions(+), 145 deletions(-) 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/README.md b/README.md index bb65306ab..8b9d2beff 100644 --- a/README.md +++ b/README.md @@ -43,7 +43,7 @@ If you are using Maven without the BOM, add this to your dependencies: com.google.cloud google-cloud-pubsub - 1.141.4 + 1.141.5 ``` @@ -51,7 +51,7 @@ If you are using Maven without the BOM, add this to your dependencies: If you are using Gradle 5.x or later, add this to your dependencies: ```Groovy -implementation platform('com.google.cloud:libraries-bom:26.68.0') +implementation platform('com.google.cloud:libraries-bom:26.69.0') implementation 'com.google.cloud:google-cloud-pubsub' ``` diff --git a/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/SubscriptionAdminClient.java b/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/SubscriptionAdminClient.java index 61b93520f..e0e70beb2 100644 --- a/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/SubscriptionAdminClient.java +++ b/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/SubscriptionAdminClient.java @@ -2406,6 +2406,7 @@ public final UnaryCallable pullCallable() { * .setClientId("clientId908408390") * .setMaxOutstandingMessages(-1315266996) * .setMaxOutstandingBytes(-2103098517) + * .setProtocolVersion(-1161610703) * .build(); * bidiStream.send(request); * for (StreamingPullResponse response : bidiStream) { diff --git a/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/SubscriptionAdminClientTest.java b/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/SubscriptionAdminClientTest.java index 6df11d0a0..c7d13c720 100644 --- a/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/SubscriptionAdminClientTest.java +++ b/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/SubscriptionAdminClientTest.java @@ -1074,6 +1074,7 @@ public void streamingPullTest() throws Exception { .setClientId("clientId908408390") .setMaxOutstandingMessages(-1315266996) .setMaxOutstandingBytes(-2103098517) + .setProtocolVersion(-1161610703) .build(); MockStreamObserver responseObserver = new MockStreamObserver<>(); @@ -1105,6 +1106,7 @@ public void streamingPullExceptionTest() throws Exception { .setClientId("clientId908408390") .setMaxOutstandingMessages(-1315266996) .setMaxOutstandingBytes(-2103098517) + .setProtocolVersion(-1161610703) .build(); MockStreamObserver responseObserver = new MockStreamObserver<>(); diff --git a/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/PubsubProto.java b/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/PubsubProto.java index 6d51da2db..0a9017c9b 100644 --- a/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/PubsubProto.java +++ b/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/PubsubProto.java @@ -835,7 +835,7 @@ public static com.google.protobuf.Descriptors.FileDescriptor getDescriptor() { + "\022AcknowledgeRequest\022@\n" + "\014subscription\030\001 \001(\tB*\340A\002\372A$\n" + "\"pubsub.googleapis.com/Subscription\022\024\n" - + "\007ack_ids\030\002 \003(\tB\003\340A\002\"\307\002\n" + + "\007ack_ids\030\002 \003(\tB\003\340A\002\"\346\002\n" + "\024StreamingPullRequest\022@\n" + "\014subscription\030\001 \001(\tB*\340A\002\372A$\n" + "\"pubsub.googleapis.com/Subscription\022\024\n" @@ -845,16 +845,18 @@ public static com.google.protobuf.Descriptors.FileDescriptor getDescriptor() { + "\033stream_ack_deadline_seconds\030\005 \001(\005B\003\340A\002\022\026\n" + "\tclient_id\030\006 \001(\tB\003\340A\001\022%\n" + "\030max_outstanding_messages\030\007 \001(\003B\003\340A\001\022\"\n" - + "\025max_outstanding_bytes\030\010 \001(\003B\003\340A\001\"\236\006\n" + + "\025max_outstanding_bytes\030\010 \001(\003B\003\340A\001\022\035\n" + + "\020protocol_version\030\n" + + " \001(\003B\003\340A\001\"\236\006\n" + "\025StreamingPullResponse\022A\n" + "\021received_messages\030\001" + " \003(\0132!.google.pubsub.v1.ReceivedMessageB\003\340A\001\022f\n" - + "\030acknowledge_confirmation\030\005 \001(\0132?.google.pubsub.v1.Stre" - + "amingPullResponse.AcknowledgeConfirmationB\003\340A\001\022t\n" - + " modify_ack_deadline_confirmation\030\003 \001(\0132E.google.pubsub.v1.StreamingPul" - + "lResponse.ModifyAckDeadlineConfirmationB\003\340A\001\022d\n" - + "\027subscription_properties\030\004 \001(\0132>." - + "google.pubsub.v1.StreamingPullResponse.SubscriptionPropertiesB\003\340A\001\032\224\001\n" + + "\030acknowledge_confirmation\030\005" + + " \001(\0132?.google.pubsub.v1.StreamingPullResponse.AcknowledgeConfirmationB\003\340A\001\022t\n" + + " modify_ack_deadline_confirmation\030\003 \001(\0132" + + "E.google.pubsub.v1.StreamingPullResponse.ModifyAckDeadlineConfirmationB\003\340A\001\022d\n" + + "\027subscription_properties\030\004 \001(\0132>.google.pu" + + "bsub.v1.StreamingPullResponse.SubscriptionPropertiesB\003\340A\001\032\224\001\n" + "\027AcknowledgeConfirmation\022\024\n" + "\007ack_ids\030\001 \003(\tB\003\340A\001\022\034\n" + "\017invalid_ack_ids\030\002 \003(\tB\003\340A\001\022\036\n" @@ -872,8 +874,8 @@ public static com.google.protobuf.Descriptors.FileDescriptor getDescriptor() { + "\036pubsub.googleapis.com/Snapshot\022@\n" + "\014subscription\030\002 \001(\tB*\340A\002\372A$\n" + "\"pubsub.googleapis.com/Subscription\022H\n" - + "\006labels\030\003" - + " \003(\01323.google.pubsub.v1.CreateSnapshotRequest.LabelsEntryB\003\340A\001\032-\n" + + "\006labels\030\003 " + + "\003(\01323.google.pubsub.v1.CreateSnapshotRequest.LabelsEntryB\003\340A\001\032-\n" + "\013LabelsEntry\022\013\n" + "\003key\030\001 \001(\t\022\r\n" + "\005value\030\002 \001(\t:\0028\001\"\200\001\n" @@ -886,141 +888,139 @@ public static com.google.protobuf.Descriptors.FileDescriptor getDescriptor() { + "\005topic\030\002 \001(\tB#\340A\001\372A\035\n" + "\033pubsub.googleapis.com/Topic\0224\n" + "\013expire_time\030\003 \001(\0132\032.google.protobuf.TimestampB\003\340A\001\022;\n" - + "\006labels\030\004 \003" - + "(\0132&.google.pubsub.v1.Snapshot.LabelsEntryB\003\340A\001\032-\n" + + "\006labels\030\004 \003(\0132&.goog" + + "le.pubsub.v1.Snapshot.LabelsEntryB\003\340A\001\032-\n" + "\013LabelsEntry\022\013\n" + "\003key\030\001 \001(\t\022\r\n" + "\005value\030\002 \001(\t:\0028\001:a\352A^\n" - + "\036pubsub.googleapis.com/Snapshot\022\'projects/{project}/snapshots/{snapshot}*" - + "\tsnapshots2\010snapshot\"N\n" - + "\022Get", - "SnapshotRequest\0228\n\010snapshot\030\001 \001(\tB&\340A\002\372A" - + " \n\036pubsub.googleapis.com/Snapshot\"\215\001\n\024Li" - + "stSnapshotsRequest\022D\n\007project\030\001 \001(\tB3\340A\002" - + "\372A-\n+cloudresourcemanager.googleapis.com" - + "/Project\022\026\n\tpage_size\030\002 \001(\005B\003\340A\001\022\027\n\npage" - + "_token\030\003 \001(\tB\003\340A\001\"i\n\025ListSnapshotsRespon" - + "se\0222\n\tsnapshots\030\001 \003(\0132\032.google.pubsub.v1" - + ".SnapshotB\003\340A\001\022\034\n\017next_page_token\030\002 \001(\tB" - + "\003\340A\001\"Q\n\025DeleteSnapshotRequest\0228\n\010snapsho" - + "t\030\001 \001(\tB&\340A\002\372A \n\036pubsub.googleapis.com/S" - + "napshot\"\306\001\n\013SeekRequest\022@\n\014subscription\030" - + "\001 \001(\tB*\340A\002\372A$\n\"pubsub.googleapis.com/Sub" - + "scription\022/\n\004time\030\002 \001(\0132\032.google.protobu" - + "f.TimestampB\003\340A\001H\000\022:\n\010snapshot\030\003 \001(\tB&\340A" - + "\001\372A \n\036pubsub.googleapis.com/SnapshotH\000B\010" - + "\n\006target\"\016\n\014SeekResponse2\270\013\n\tPublisher\022q" - + "\n\013CreateTopic\022\027.google.pubsub.v1.Topic\032\027" - + ".google.pubsub.v1.Topic\"0\332A\004name\202\323\344\223\002#\032\036" - + "/v1/{name=projects/*/topics/*}:\001*\022\221\001\n\013Up" - + "dateTopic\022$.google.pubsub.v1.UpdateTopic" - + "Request\032\027.google.pubsub.v1.Topic\"C\332A\021top" - + "ic,update_mask\202\323\344\223\002)2$/v1/{topic.name=pr" - + "ojects/*/topics/*}:\001*\022\223\001\n\007Publish\022 .goog" - + "le.pubsub.v1.PublishRequest\032!.google.pub" - + "sub.v1.PublishResponse\"C\332A\016topic,message" - + "s\202\323\344\223\002,\"\'/v1/{topic=projects/*/topics/*}" - + ":publish:\001*\022w\n\010GetTopic\022!.google.pubsub." - + "v1.GetTopicRequest\032\027.google.pubsub.v1.To" - + "pic\"/\332A\005topic\202\323\344\223\002!\022\037/v1/{topic=projects" - + "/*/topics/*}\022\212\001\n\nListTopics\022#.google.pub" - + "sub.v1.ListTopicsRequest\032$.google.pubsub" - + ".v1.ListTopicsResponse\"1\332A\007project\202\323\344\223\002!" - + "\022\037/v1/{project=projects/*}/topics\022\272\001\n\026Li" - + "stTopicSubscriptions\022/.google.pubsub.v1." - + "ListTopicSubscriptionsRequest\0320.google.p" - + "ubsub.v1.ListTopicSubscriptionsResponse\"" - + "=\332A\005topic\202\323\344\223\002/\022-/v1/{topic=projects/*/t" - + "opics/*}/subscriptions\022\252\001\n\022ListTopicSnap" - + "shots\022+.google.pubsub.v1.ListTopicSnapsh" - + "otsRequest\032,.google.pubsub.v1.ListTopicS" - + "napshotsResponse\"9\332A\005topic\202\323\344\223\002+\022)/v1/{t" - + "opic=projects/*/topics/*}/snapshots\022|\n\013D" - + "eleteTopic\022$.google.pubsub.v1.DeleteTopi" - + "cRequest\032\026.google.protobuf.Empty\"/\332A\005top" - + "ic\202\323\344\223\002!*\037/v1/{topic=projects/*/topics/*" - + "}\022\255\001\n\022DetachSubscription\022+.google.pubsub" - + ".v1.DetachSubscriptionRequest\032,.google.p" - + "ubsub.v1.DetachSubscriptionResponse\"<\202\323\344" - + "\223\0026\"4/v1/{subscription=projects/*/subscr" - + "iptions/*}:detach\032p\312A\025pubsub.googleapis." - + "com\322AUhttps://www.googleapis.com/auth/cl" - + "oud-platform,https://www.googleapis.com/" - + "auth/pubsub2\322\025\n\nSubscriber\022\264\001\n\022CreateSub" - + "scription\022\036.google.pubsub.v1.Subscriptio" - + "n\032\036.google.pubsub.v1.Subscription\"^\332A+na" - + "me,topic,push_config,ack_deadline_second" - + "s\202\323\344\223\002*\032%/v1/{name=projects/*/subscripti" - + "ons/*}:\001*\022\241\001\n\017GetSubscription\022(.google.p" - + "ubsub.v1.GetSubscriptionRequest\032\036.google" - + ".pubsub.v1.Subscription\"D\332A\014subscription" - + "\202\323\344\223\002/\022-/v1/{subscription=projects/*/sub" - + "scriptions/*}\022\273\001\n\022UpdateSubscription\022+.g" - + "oogle.pubsub.v1.UpdateSubscriptionReques" - + "t\032\036.google.pubsub.v1.Subscription\"X\332A\030su" - + "bscription,update_mask\202\323\344\223\002722/v1/{subsc" - + "ription.name=projects/*/subscriptions/*}" - + ":\001*\022\246\001\n\021ListSubscriptions\022*.google.pubsu" - + "b.v1.ListSubscriptionsRequest\032+.google.p" - + "ubsub.v1.ListSubscriptionsResponse\"8\332A\007p" - + "roject\202\323\344\223\002(\022&/v1/{project=projects/*}/s" - + "ubscriptions\022\237\001\n\022DeleteSubscription\022+.go" - + "ogle.pubsub.v1.DeleteSubscriptionRequest" - + "\032\026.google.protobuf.Empty\"D\332A\014subscriptio" - + "n\202\323\344\223\002/*-/v1/{subscription=projects/*/su" - + "bscriptions/*}\022\317\001\n\021ModifyAckDeadline\022*.g" - + "oogle.pubsub.v1.ModifyAckDeadlineRequest" - + "\032\026.google.protobuf.Empty\"v\332A)subscriptio" - + "n,ack_ids,ack_deadline_seconds\202\323\344\223\002D\"?/v" - + "1/{subscription=projects/*/subscriptions" - + "/*}:modifyAckDeadline:\001*\022\250\001\n\013Acknowledge" - + "\022$.google.pubsub.v1.AcknowledgeRequest\032\026" - + ".google.protobuf.Empty\"[\332A\024subscription," - + "ack_ids\202\323\344\223\002>\"9/v1/{subscription=project" - + "s/*/subscriptions/*}:acknowledge:\001*\022\320\001\n\004" - + "Pull\022\035.google.pubsub.v1.PullRequest\032\036.go" - + "ogle.pubsub.v1.PullResponse\"\210\001\332A,subscri" - + "ption,return_immediately,max_messages\332A\031" - + "subscription,max_messages\202\323\344\223\0027\"2/v1/{su" - + "bscription=projects/*/subscriptions/*}:p" - + "ull:\001*\022f\n\rStreamingPull\022&.google.pubsub." - + "v1.StreamingPullRequest\032\'.google.pubsub." - + "v1.StreamingPullResponse\"\000(\0010\001\022\273\001\n\020Modif" - + "yPushConfig\022).google.pubsub.v1.ModifyPus" - + "hConfigRequest\032\026.google.protobuf.Empty\"d" - + "\332A\030subscription,push_config\202\323\344\223\002C\">/v1/{" - + "subscription=projects/*/subscriptions/*}" - + ":modifyPushConfig:\001*\022\211\001\n\013GetSnapshot\022$.g" - + "oogle.pubsub.v1.GetSnapshotRequest\032\032.goo" - + "gle.pubsub.v1.Snapshot\"8\332A\010snapshot\202\323\344\223\002" - + "\'\022%/v1/{snapshot=projects/*/snapshots/*}" - + "\022\226\001\n\rListSnapshots\022&.google.pubsub.v1.Li" - + "stSnapshotsRequest\032\'.google.pubsub.v1.Li" - + "stSnapshotsResponse\"4\332A\007project\202\323\344\223\002$\022\"/" - + "v1/{project=projects/*}/snapshots\022\227\001\n\016Cr" - + "eateSnapshot\022\'.google.pubsub.v1.CreateSn" - + "apshotRequest\032\032.google.pubsub.v1.Snapsho" - + "t\"@\332A\021name,subscription\202\323\344\223\002&\032!/v1/{name" - + "=projects/*/snapshots/*}:\001*\022\243\001\n\016UpdateSn" - + "apshot\022\'.google.pubsub.v1.UpdateSnapshot" - + "Request\032\032.google.pubsub.v1.Snapshot\"L\332A\024" - + "snapshot,update_mask\202\323\344\223\002/2*/v1/{snapsho" - + "t.name=projects/*/snapshots/*}:\001*\022\213\001\n\016De" - + "leteSnapshot\022\'.google.pubsub.v1.DeleteSn" - + "apshotRequest\032\026.google.protobuf.Empty\"8\332" - + "A\010snapshot\202\323\344\223\002\'*%/v1/{snapshot=projects" - + "/*/snapshots/*}\022\204\001\n\004Seek\022\035.google.pubsub" - + ".v1.SeekRequest\032\036.google.pubsub.v1.SeekR" - + "esponse\"=\202\323\344\223\0027\"2/v1/{subscription=proje" - + "cts/*/subscriptions/*}:seek:\001*\032p\312A\025pubsu" - + "b.googleapis.com\322AUhttps://www.googleapi" - + "s.com/auth/cloud-platform,https://www.go" - + "ogleapis.com/auth/pubsubB\252\001\n\024com.google." - + "pubsub.v1B\013PubsubProtoP\001Z5cloud.google.c" - + "om/go/pubsub/v2/apiv1/pubsubpb;pubsubpb\252" - + "\002\026Google.Cloud.PubSub.V1\312\002\026Google\\Cloud\\" - + "PubSub\\V1\352\002\031Google::Cloud::PubSub::V1b\006p" - + "roto3" + + "\036pubsub.googleapis.com/Snapshot\022\'projects/{project}/snapshots/{snapsh", + "ot}*\tsnapshots2\010snapshot\"N\n\022GetSnapshotR" + + "equest\0228\n\010snapshot\030\001 \001(\tB&\340A\002\372A \n\036pubsub" + + ".googleapis.com/Snapshot\"\215\001\n\024ListSnapsho" + + "tsRequest\022D\n\007project\030\001 \001(\tB3\340A\002\372A-\n+clou" + + "dresourcemanager.googleapis.com/Project\022" + + "\026\n\tpage_size\030\002 \001(\005B\003\340A\001\022\027\n\npage_token\030\003 " + + "\001(\tB\003\340A\001\"i\n\025ListSnapshotsResponse\0222\n\tsna" + + "pshots\030\001 \003(\0132\032.google.pubsub.v1.Snapshot" + + "B\003\340A\001\022\034\n\017next_page_token\030\002 \001(\tB\003\340A\001\"Q\n\025D" + + "eleteSnapshotRequest\0228\n\010snapshot\030\001 \001(\tB&" + + "\340A\002\372A \n\036pubsub.googleapis.com/Snapshot\"\306" + + "\001\n\013SeekRequest\022@\n\014subscription\030\001 \001(\tB*\340A" + + "\002\372A$\n\"pubsub.googleapis.com/Subscription" + + "\022/\n\004time\030\002 \001(\0132\032.google.protobuf.Timesta" + + "mpB\003\340A\001H\000\022:\n\010snapshot\030\003 \001(\tB&\340A\001\372A \n\036pub" + + "sub.googleapis.com/SnapshotH\000B\010\n\006target\"" + + "\016\n\014SeekResponse2\270\013\n\tPublisher\022q\n\013CreateT" + + "opic\022\027.google.pubsub.v1.Topic\032\027.google.p" + + "ubsub.v1.Topic\"0\332A\004name\202\323\344\223\002#\032\036/v1/{name" + + "=projects/*/topics/*}:\001*\022\221\001\n\013UpdateTopic" + + "\022$.google.pubsub.v1.UpdateTopicRequest\032\027" + + ".google.pubsub.v1.Topic\"C\332A\021topic,update" + + "_mask\202\323\344\223\002)2$/v1/{topic.name=projects/*/" + + "topics/*}:\001*\022\223\001\n\007Publish\022 .google.pubsub" + + ".v1.PublishRequest\032!.google.pubsub.v1.Pu" + + "blishResponse\"C\332A\016topic,messages\202\323\344\223\002,\"\'" + + "/v1/{topic=projects/*/topics/*}:publish:" + + "\001*\022w\n\010GetTopic\022!.google.pubsub.v1.GetTop" + + "icRequest\032\027.google.pubsub.v1.Topic\"/\332A\005t" + + "opic\202\323\344\223\002!\022\037/v1/{topic=projects/*/topics" + + "/*}\022\212\001\n\nListTopics\022#.google.pubsub.v1.Li" + + "stTopicsRequest\032$.google.pubsub.v1.ListT" + + "opicsResponse\"1\332A\007project\202\323\344\223\002!\022\037/v1/{pr" + + "oject=projects/*}/topics\022\272\001\n\026ListTopicSu" + + "bscriptions\022/.google.pubsub.v1.ListTopic" + + "SubscriptionsRequest\0320.google.pubsub.v1." + + "ListTopicSubscriptionsResponse\"=\332A\005topic" + + "\202\323\344\223\002/\022-/v1/{topic=projects/*/topics/*}/" + + "subscriptions\022\252\001\n\022ListTopicSnapshots\022+.g" + + "oogle.pubsub.v1.ListTopicSnapshotsReques" + + "t\032,.google.pubsub.v1.ListTopicSnapshotsR" + + "esponse\"9\332A\005topic\202\323\344\223\002+\022)/v1/{topic=proj" + + "ects/*/topics/*}/snapshots\022|\n\013DeleteTopi" + + "c\022$.google.pubsub.v1.DeleteTopicRequest\032" + + "\026.google.protobuf.Empty\"/\332A\005topic\202\323\344\223\002!*" + + "\037/v1/{topic=projects/*/topics/*}\022\255\001\n\022Det" + + "achSubscription\022+.google.pubsub.v1.Detac" + + "hSubscriptionRequest\032,.google.pubsub.v1." + + "DetachSubscriptionResponse\"<\202\323\344\223\0026\"4/v1/" + + "{subscription=projects/*/subscriptions/*" + + "}:detach\032p\312A\025pubsub.googleapis.com\322AUhtt" + + "ps://www.googleapis.com/auth/cloud-platf" + + "orm,https://www.googleapis.com/auth/pubs" + + "ub2\322\025\n\nSubscriber\022\264\001\n\022CreateSubscription" + + "\022\036.google.pubsub.v1.Subscription\032\036.googl" + + "e.pubsub.v1.Subscription\"^\332A+name,topic," + + "push_config,ack_deadline_seconds\202\323\344\223\002*\032%" + + "/v1/{name=projects/*/subscriptions/*}:\001*" + + "\022\241\001\n\017GetSubscription\022(.google.pubsub.v1." + + "GetSubscriptionRequest\032\036.google.pubsub.v" + + "1.Subscription\"D\332A\014subscription\202\323\344\223\002/\022-/" + + "v1/{subscription=projects/*/subscription" + + "s/*}\022\273\001\n\022UpdateSubscription\022+.google.pub" + + "sub.v1.UpdateSubscriptionRequest\032\036.googl" + + "e.pubsub.v1.Subscription\"X\332A\030subscriptio" + + "n,update_mask\202\323\344\223\002722/v1/{subscription.n" + + "ame=projects/*/subscriptions/*}:\001*\022\246\001\n\021L" + + "istSubscriptions\022*.google.pubsub.v1.List" + + "SubscriptionsRequest\032+.google.pubsub.v1." + + "ListSubscriptionsResponse\"8\332A\007project\202\323\344" + + "\223\002(\022&/v1/{project=projects/*}/subscripti" + + "ons\022\237\001\n\022DeleteSubscription\022+.google.pubs" + + "ub.v1.DeleteSubscriptionRequest\032\026.google" + + ".protobuf.Empty\"D\332A\014subscription\202\323\344\223\002/*-" + + "/v1/{subscription=projects/*/subscriptio" + + "ns/*}\022\317\001\n\021ModifyAckDeadline\022*.google.pub" + + "sub.v1.ModifyAckDeadlineRequest\032\026.google" + + ".protobuf.Empty\"v\332A)subscription,ack_ids" + + ",ack_deadline_seconds\202\323\344\223\002D\"?/v1/{subscr" + + "iption=projects/*/subscriptions/*}:modif" + + "yAckDeadline:\001*\022\250\001\n\013Acknowledge\022$.google" + + ".pubsub.v1.AcknowledgeRequest\032\026.google.p" + + "rotobuf.Empty\"[\332A\024subscription,ack_ids\202\323" + + "\344\223\002>\"9/v1/{subscription=projects/*/subsc" + + "riptions/*}:acknowledge:\001*\022\320\001\n\004Pull\022\035.go" + + "ogle.pubsub.v1.PullRequest\032\036.google.pubs" + + "ub.v1.PullResponse\"\210\001\332A,subscription,ret" + + "urn_immediately,max_messages\332A\031subscript" + + "ion,max_messages\202\323\344\223\0027\"2/v1/{subscriptio" + + "n=projects/*/subscriptions/*}:pull:\001*\022f\n" + + "\rStreamingPull\022&.google.pubsub.v1.Stream" + + "ingPullRequest\032\'.google.pubsub.v1.Stream" + + "ingPullResponse\"\000(\0010\001\022\273\001\n\020ModifyPushConf" + + "ig\022).google.pubsub.v1.ModifyPushConfigRe" + + "quest\032\026.google.protobuf.Empty\"d\332A\030subscr" + + "iption,push_config\202\323\344\223\002C\">/v1/{subscript" + + "ion=projects/*/subscriptions/*}:modifyPu" + + "shConfig:\001*\022\211\001\n\013GetSnapshot\022$.google.pub" + + "sub.v1.GetSnapshotRequest\032\032.google.pubsu" + + "b.v1.Snapshot\"8\332A\010snapshot\202\323\344\223\002\'\022%/v1/{s" + + "napshot=projects/*/snapshots/*}\022\226\001\n\rList" + + "Snapshots\022&.google.pubsub.v1.ListSnapsho" + + "tsRequest\032\'.google.pubsub.v1.ListSnapsho" + + "tsResponse\"4\332A\007project\202\323\344\223\002$\022\"/v1/{proje" + + "ct=projects/*}/snapshots\022\227\001\n\016CreateSnaps" + + "hot\022\'.google.pubsub.v1.CreateSnapshotReq" + + "uest\032\032.google.pubsub.v1.Snapshot\"@\332A\021nam" + + "e,subscription\202\323\344\223\002&\032!/v1/{name=projects" + + "/*/snapshots/*}:\001*\022\243\001\n\016UpdateSnapshot\022\'." + + "google.pubsub.v1.UpdateSnapshotRequest\032\032" + + ".google.pubsub.v1.Snapshot\"L\332A\024snapshot," + + "update_mask\202\323\344\223\002/2*/v1/{snapshot.name=pr" + + "ojects/*/snapshots/*}:\001*\022\213\001\n\016DeleteSnaps" + + "hot\022\'.google.pubsub.v1.DeleteSnapshotReq" + + "uest\032\026.google.protobuf.Empty\"8\332A\010snapsho" + + "t\202\323\344\223\002\'*%/v1/{snapshot=projects/*/snapsh" + + "ots/*}\022\204\001\n\004Seek\022\035.google.pubsub.v1.SeekR" + + "equest\032\036.google.pubsub.v1.SeekResponse\"=" + + "\202\323\344\223\0027\"2/v1/{subscription=projects/*/sub" + + "scriptions/*}:seek:\001*\032p\312A\025pubsub.googlea" + + "pis.com\322AUhttps://www.googleapis.com/aut" + + "h/cloud-platform,https://www.googleapis." + + "com/auth/pubsubB\252\001\n\024com.google.pubsub.v1" + + "B\013PubsubProtoP\001Z5cloud.google.com/go/pub" + + "sub/v2/apiv1/pubsubpb;pubsubpb\252\002\026Google." + + "Cloud.PubSub.V1\312\002\026Google\\Cloud\\PubSub\\V1" + + "\352\002\031Google::Cloud::PubSub::V1b\006proto3" }; descriptor = com.google.protobuf.Descriptors.FileDescriptor.internalBuildGeneratedFileFrom( @@ -1699,6 +1699,7 @@ public static com.google.protobuf.Descriptors.FileDescriptor getDescriptor() { "ClientId", "MaxOutstandingMessages", "MaxOutstandingBytes", + "ProtocolVersion", }); internal_static_google_pubsub_v1_StreamingPullResponse_descriptor = getDescriptor().getMessageTypes().get(41); diff --git a/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/StreamingPullRequest.java b/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/StreamingPullRequest.java index 9a68de42d..b24d3d922 100644 --- a/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/StreamingPullRequest.java +++ b/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/StreamingPullRequest.java @@ -531,6 +531,27 @@ public long getMaxOutstandingBytes() { return maxOutstandingBytes_; } + public static final int PROTOCOL_VERSION_FIELD_NUMBER = 10; + private long protocolVersion_ = 0L; + + /** + * + * + * 
+   * Optional. The protocol version used by the client. This property can only
+   * be set on the initial StreamingPullRequest. If it is set on a subsequent
+   * request, the stream will be aborted with status `INVALID_ARGUMENT`.
+   *
+ * + * int64 protocol_version = 10 [(.google.api.field_behavior) = OPTIONAL]; + * + * @return The protocolVersion. + */ + @java.lang.Override + public long getProtocolVersion() { + return protocolVersion_; + } + private byte memoizedIsInitialized = -1; @java.lang.Override @@ -575,6 +596,9 @@ public void writeTo(com.google.protobuf.CodedOutputStream output) throws java.io if (maxOutstandingBytes_ != 0L) { output.writeInt64(8, maxOutstandingBytes_); } + if (protocolVersion_ != 0L) { + output.writeInt64(10, protocolVersion_); + } getUnknownFields().writeTo(output); } @@ -629,6 +653,9 @@ public int getSerializedSize() { if (maxOutstandingBytes_ != 0L) { size += com.google.protobuf.CodedOutputStream.computeInt64Size(8, maxOutstandingBytes_); } + if (protocolVersion_ != 0L) { + size += com.google.protobuf.CodedOutputStream.computeInt64Size(10, protocolVersion_); + } size += getUnknownFields().getSerializedSize(); memoizedSize = size; return size; @@ -653,6 +680,7 @@ public boolean equals(final java.lang.Object obj) { if (!getClientId().equals(other.getClientId())) return false; if (getMaxOutstandingMessages() != other.getMaxOutstandingMessages()) return false; if (getMaxOutstandingBytes() != other.getMaxOutstandingBytes()) return false; + if (getProtocolVersion() != other.getProtocolVersion()) return false; if (!getUnknownFields().equals(other.getUnknownFields())) return false; return true; } @@ -686,6 +714,8 @@ public int hashCode() { hash = (53 * hash) + com.google.protobuf.Internal.hashLong(getMaxOutstandingMessages()); hash = (37 * hash) + MAX_OUTSTANDING_BYTES_FIELD_NUMBER; hash = (53 * hash) + com.google.protobuf.Internal.hashLong(getMaxOutstandingBytes()); + hash = (37 * hash) + PROTOCOL_VERSION_FIELD_NUMBER; + hash = (53 * hash) + com.google.protobuf.Internal.hashLong(getProtocolVersion()); hash = (29 * hash) + getUnknownFields().hashCode(); memoizedHashCode = hash; return hash; @@ -836,6 +866,7 @@ public Builder clear() { clientId_ = ""; maxOutstandingMessages_ = 0L; maxOutstandingBytes_ = 0L; + protocolVersion_ = 0L; return this; } @@ -899,6 +930,9 @@ private void buildPartial0(com.google.pubsub.v1.StreamingPullRequest result) { if (((from_bitField0_ & 0x00000080) != 0)) { result.maxOutstandingBytes_ = maxOutstandingBytes_; } + if (((from_bitField0_ & 0x00000100) != 0)) { + result.protocolVersion_ = protocolVersion_; + } } @java.lang.Override @@ -996,6 +1030,9 @@ public Builder mergeFrom(com.google.pubsub.v1.StreamingPullRequest other) { if (other.getMaxOutstandingBytes() != 0L) { setMaxOutstandingBytes(other.getMaxOutstandingBytes()); } + if (other.getProtocolVersion() != 0L) { + setProtocolVersion(other.getProtocolVersion()); + } this.mergeUnknownFields(other.getUnknownFields()); onChanged(); return this; @@ -1084,6 +1121,12 @@ public Builder mergeFrom( bitField0_ |= 0x00000080; break; } // case 64 + case 80: + { + protocolVersion_ = input.readInt64(); + bitField0_ |= 0x00000100; + break; + } // case 80 default: { if (!super.parseUnknownField(input, extensionRegistry, tag)) { @@ -2262,6 +2305,68 @@ public Builder clearMaxOutstandingBytes() { return this; } + private long protocolVersion_; + + /** + * + * + * 
+     * Optional. The protocol version used by the client. This property can only
+     * be set on the initial StreamingPullRequest. If it is set on a subsequent
+     * request, the stream will be aborted with status `INVALID_ARGUMENT`.
+     *
+ * + * int64 protocol_version = 10 [(.google.api.field_behavior) = OPTIONAL]; + * + * @return The protocolVersion. + */ + @java.lang.Override + public long getProtocolVersion() { + return protocolVersion_; + } + + /** + * + * + * 
+     * Optional. The protocol version used by the client. This property can only
+     * be set on the initial StreamingPullRequest. If it is set on a subsequent
+     * request, the stream will be aborted with status `INVALID_ARGUMENT`.
+     *
+ * + * int64 protocol_version = 10 [(.google.api.field_behavior) = OPTIONAL]; + * + * @param value The protocolVersion to set. + * @return This builder for chaining. + */ + public Builder setProtocolVersion(long value) { + + protocolVersion_ = value; + bitField0_ |= 0x00000100; + onChanged(); + return this; + } + + /** + * + * + * 
+     * Optional. The protocol version used by the client. This property can only
+     * be set on the initial StreamingPullRequest. If it is set on a subsequent
+     * request, the stream will be aborted with status `INVALID_ARGUMENT`.
+     *
+ * + * int64 protocol_version = 10 [(.google.api.field_behavior) = OPTIONAL]; + * + * @return This builder for chaining. + */ + public Builder clearProtocolVersion() { + bitField0_ = (bitField0_ & ~0x00000100); + protocolVersion_ = 0L; + onChanged(); + return this; + } + @java.lang.Override public final Builder setUnknownFields(final com.google.protobuf.UnknownFieldSet unknownFields) { return super.setUnknownFields(unknownFields); diff --git a/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/StreamingPullRequestOrBuilder.java b/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/StreamingPullRequestOrBuilder.java index 0e7f069b4..d23cb626e 100644 --- a/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/StreamingPullRequestOrBuilder.java +++ b/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/StreamingPullRequestOrBuilder.java @@ -370,4 +370,19 @@ public interface StreamingPullRequestOrBuilder * @return The maxOutstandingBytes. */ long getMaxOutstandingBytes(); + + /** + * + * + * 
+   * Optional. The protocol version used by the client. This property can only
+   * be set on the initial StreamingPullRequest. If it is set on a subsequent
+   * request, the stream will be aborted with status `INVALID_ARGUMENT`.
+   *
+ * + * int64 protocol_version = 10 [(.google.api.field_behavior) = OPTIONAL]; + * + * @return The protocolVersion. + */ + long getProtocolVersion(); } diff --git a/proto-google-cloud-pubsub-v1/src/main/proto/google/pubsub/v1/pubsub.proto b/proto-google-cloud-pubsub-v1/src/main/proto/google/pubsub/v1/pubsub.proto index 5a8bb0768..125b907f6 100644 --- a/proto-google-cloud-pubsub-v1/src/main/proto/google/pubsub/v1/pubsub.proto +++ b/proto-google-cloud-pubsub-v1/src/main/proto/google/pubsub/v1/pubsub.proto @@ -2124,6 +2124,11 @@ message StreamingPullRequest { // set on a subsequent request, the stream will be aborted with status // `INVALID_ARGUMENT`. int64 max_outstanding_bytes = 8 [(google.api.field_behavior) = OPTIONAL]; + + // Optional. The protocol version used by the client. This property can only + // be set on the initial StreamingPullRequest. If it is set on a subsequent + // request, the stream will be aborted with status `INVALID_ARGUMENT`. + int64 protocol_version = 10 [(google.api.field_behavior) = OPTIONAL]; } // Response for the `StreamingPull` method. This response is used to stream From ded339e6355afd33e0bc0afbbeac05c63890cb03 Mon Sep 17 00:00:00 2001 From: cloud-java-bot Date: Wed, 1 Oct 2025 02:35:04 +0000 Subject: [PATCH 3/6] chore: Update generation configuration at Wed Oct 1 02:34:55 UTC 2025 --- generation_config.yaml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/generation_config.yaml b/generation_config.yaml index 80fe2e371..83182a681 100644 --- a/generation_config.yaml +++ b/generation_config.yaml @@ -1,5 +1,5 @@ gapic_generator_version: 2.62.2 -googleapis_commitish: eab82ec804dfd76372ca369910ccd0766ee02e5c +googleapis_commitish: 063f9e19c5890182920980ced75828fd7c0588a5 libraries_bom_version: 26.69.0 libraries: - api_shortname: pubsub From fa911a7e3925d32019e4deee61f420e440bc8254 Mon Sep 17 00:00:00 2001 From: cloud-java-bot Date: Thu, 2 Oct 2025 02:29:47 +0000 Subject: [PATCH 4/6] chore: Update generation configuration at Thu Oct 2 02:29:38 UTC 2025 --- generation_config.yaml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/generation_config.yaml b/generation_config.yaml index 83182a681..f02bae8ed 100644 --- a/generation_config.yaml +++ b/generation_config.yaml @@ -1,5 +1,5 @@ gapic_generator_version: 2.62.2 -googleapis_commitish: 063f9e19c5890182920980ced75828fd7c0588a5 +googleapis_commitish: 3990e05b25dcaf7ba8d6baa4255d9b012a3a6a4f libraries_bom_version: 26.69.0 libraries: - api_shortname: pubsub From acd8850313ba0c87976799c797ca3eeb5f07c1a4 Mon Sep 17 00:00:00 2001 From: cloud-java-bot Date: Fri, 3 Oct 2025 02:29:22 +0000 Subject: [PATCH 5/6] chore: Update generation configuration at Fri Oct 3 02:29:13 UTC 2025 --- .github/workflows/hermetic_library_generation.yaml | 2 +- generation_config.yaml | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/.github/workflows/hermetic_library_generation.yaml b/.github/workflows/hermetic_library_generation.yaml index 640f7bbd5..0e85f8052 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.62.2 + - uses: googleapis/sdk-platform-java/.github/scripts@v2.62.3 if: env.SHOULD_RUN == 'true' with: base_ref: ${{ github.base_ref }} diff --git a/generation_config.yaml b/generation_config.yaml index f02bae8ed..b8c06cfa0 100644 --- a/generation_config.yaml +++ b/generation_config.yaml @@ -1,5 +1,5 @@ -gapic_generator_version: 2.62.2 -googleapis_commitish: 3990e05b25dcaf7ba8d6baa4255d9b012a3a6a4f +gapic_generator_version: 2.62.3 +googleapis_commitish: 9070e63a1f574261c153ef6e94afc55677200337 libraries_bom_version: 26.69.0 libraries: - api_shortname: pubsub From c4f6d3d6851e6c852d9e67729e4b8f6e888ed1cd Mon Sep 17 00:00:00 2001 From: cloud-java-bot Date: Fri, 3 Oct 2025 02:31:47 +0000 Subject: [PATCH 6/6] chore: generate libraries at Fri Oct 3 02:29:47 UTC 2025 --- .github/workflows/ci.yaml | 2 +- .kokoro/presubmit/graalvm-native-a.cfg | 2 +- .kokoro/presubmit/graalvm-native-b.cfg | 2 +- .kokoro/presubmit/graalvm-native-c.cfg | 2 +- 4 files changed, 4 insertions(+), 4 deletions(-) diff --git a/.github/workflows/ci.yaml b/.github/workflows/ci.yaml index 10acf46ac..b9b8be0c3 100644 --- a/.github/workflows/ci.yaml +++ b/.github/workflows/ci.yaml @@ -25,7 +25,7 @@ jobs: strategy: fail-fast: false matrix: - java: [11, 17, 21, 24] + java: [11, 17, 21, 25] steps: - uses: actions/checkout@v4 - uses: actions/setup-java@v4 diff --git a/.kokoro/presubmit/graalvm-native-a.cfg b/.kokoro/presubmit/graalvm-native-a.cfg index 5554627da..b7567eeb7 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.52.2" # {x-version-update:google-cloud-shared-dependencies:current} + value: "gcr.io/cloud-devrel-public-resources/graalvm_sdk_platform_a:3.52.3" # {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 108943740..c7205f0ab 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.52.2" # {x-version-update:google-cloud-shared-dependencies:current} + value: "gcr.io/cloud-devrel-public-resources/graalvm_sdk_platform_b:3.52.3" # {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 5465e5192..f6ab8976a 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.52.2" # {x-version-update:google-cloud-shared-dependencies:current} + value: "gcr.io/cloud-devrel-public-resources/graalvm_sdk_platform_c:3.52.3" # {x-version-update:google-cloud-shared-dependencies:current} } env_vars: {