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