Sample code: + * + *
+ * try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) {
+ * ProjectSnapshotName snapshot = ProjectSnapshotName.of("[PROJECT]", "[SNAPSHOT]");
+ * Snapshot response = subscriptionAdminClient.getSnapshot(snapshot);
+ * }
+ * Sample code: + * + *
+ * try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) {
+ * ProjectSnapshotName snapshot = ProjectSnapshotName.of("[PROJECT]", "[SNAPSHOT]");
+ * Snapshot response = subscriptionAdminClient.getSnapshot(snapshot.toString());
+ * }
+ * Sample code: + * + *
+ * try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) {
+ * ProjectSnapshotName snapshot = ProjectSnapshotName.of("[PROJECT]", "[SNAPSHOT]");
+ * GetSnapshotRequest request = GetSnapshotRequest.newBuilder()
+ * .setSnapshot(snapshot.toString())
+ * .build();
+ * Snapshot response = subscriptionAdminClient.getSnapshot(request);
+ * }
+ * Sample code: + * + *
+ * try (SubscriptionAdminClient subscriptionAdminClient = SubscriptionAdminClient.create()) {
+ * ProjectSnapshotName snapshot = ProjectSnapshotName.of("[PROJECT]", "[SNAPSHOT]");
+ * GetSnapshotRequest request = GetSnapshotRequest.newBuilder()
+ * .setSnapshot(snapshot.toString())
+ * .build();
+ * ApiFuture<Snapshot> future = subscriptionAdminClient.getSnapshotCallable().futureCall(request);
+ * // Do something
+ * Snapshot response = future.get();
+ * }
+ * Can return Public Errors: NOT_FOUND, INVALID_ARGUMENT and PERMISSION_DENIED + *
Can return `NOT_FOUND`, `INVALID_ARGUMENT`, and `PERMISSION_DENIED` errors. * *
Sample code: * @@ -2046,7 +2151,7 @@ public final Policy setIamPolicy(String resource, Policy policy) { /** * Sets the access control policy on the specified resource. Replaces any existing policy. * - *
Can return Public Errors: NOT_FOUND, INVALID_ARGUMENT and PERMISSION_DENIED + *
Can return `NOT_FOUND`, `INVALID_ARGUMENT`, and `PERMISSION_DENIED` errors. * *
Sample code:
*
@@ -2142,7 +2247,7 @@ public final UnaryCallable Note: This operation is designed to be used for building permission-aware UIs and
* command-line tools, not for authorization checking. This operation may "fail open" without
@@ -2209,7 +2314,7 @@ public final TestIamPermissionsResponse testIamPermissions(
// AUTO-GENERATED DOCUMENTATION AND METHOD
/**
* Returns permissions that a caller has on the specified resource. If the resource does not
- * exist, this will return an empty set of permissions, not a NOT_FOUND error.
+ * exist, this will return an empty set of permissions, not a `NOT_FOUND` error.
*
* Note: This operation is designed to be used for building permission-aware UIs and
* command-line tools, not for authorization checking. This operation may "fail open" without
diff --git a/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/SubscriptionAdminSettings.java b/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/SubscriptionAdminSettings.java
index 32e5a6c5c..06d12d8ff 100644
--- a/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/SubscriptionAdminSettings.java
+++ b/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/SubscriptionAdminSettings.java
@@ -41,6 +41,7 @@
import com.google.pubsub.v1.CreateSnapshotRequest;
import com.google.pubsub.v1.DeleteSnapshotRequest;
import com.google.pubsub.v1.DeleteSubscriptionRequest;
+import com.google.pubsub.v1.GetSnapshotRequest;
import com.google.pubsub.v1.GetSubscriptionRequest;
import com.google.pubsub.v1.ListSnapshotsRequest;
import com.google.pubsub.v1.ListSnapshotsResponse;
@@ -122,6 +123,11 @@ public UnaryCallSettings Sample code:
+ *
+ * Sample code:
+ *
+ * Sample code:
+ *
+ * Sample code:
+ *
+ * Sample code:
+ *
+ * Can return Public Errors: NOT_FOUND, INVALID_ARGUMENT and PERMISSION_DENIED
+ * Can return `NOT_FOUND`, `INVALID_ARGUMENT`, and `PERMISSION_DENIED` errors.
*
* Sample code:
*
@@ -1073,7 +1226,7 @@ public final Policy setIamPolicy(String resource, Policy policy) {
/**
* Sets the access control policy on the specified resource. Replaces any existing policy.
*
- * Can return Public Errors: NOT_FOUND, INVALID_ARGUMENT and PERMISSION_DENIED
+ * Can return `NOT_FOUND`, `INVALID_ARGUMENT`, and `PERMISSION_DENIED` errors.
*
* Sample code:
*
@@ -1169,7 +1322,7 @@ public final UnaryCallable Note: This operation is designed to be used for building permission-aware UIs and
* command-line tools, not for authorization checking. This operation may "fail open" without
@@ -1236,7 +1389,7 @@ public final TestIamPermissionsResponse testIamPermissions(
// AUTO-GENERATED DOCUMENTATION AND METHOD
/**
* Returns permissions that a caller has on the specified resource. If the resource does not
- * exist, this will return an empty set of permissions, not a NOT_FOUND error.
+ * exist, this will return an empty set of permissions, not a `NOT_FOUND` error.
*
* Note: This operation is designed to be used for building permission-aware UIs and
* command-line tools, not for authorization checking. This operation may "fail open" without
@@ -1501,4 +1654,86 @@ public ProjectSubscriptionName apply(String arg0) {
});
}
}
+
+ public static class ListTopicSnapshotsPagedResponse
+ extends AbstractPagedListResponse<
+ ListTopicSnapshotsRequest,
+ ListTopicSnapshotsResponse,
+ String,
+ ListTopicSnapshotsPage,
+ ListTopicSnapshotsFixedSizeCollection> {
+
+ public static ApiFuture
+ *
+ * @param topic Required. The name of the topic that snapshots are attached to. Format is
+ * `projects/{project}/topics/{topic}`.
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ /* package-private */ final ListTopicSnapshotsPagedResponse listTopicSnapshots(TopicName topic) {
+ ListTopicSnapshotsRequest request =
+ ListTopicSnapshotsRequest.newBuilder()
+ .setTopic(topic == null ? null : topic.toString())
+ .build();
+ return listTopicSnapshots(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD
+ /**
+ * Lists the names of the snapshots on this topic. Snapshots are used in <a
+ * href="https://cloud.google.com/pubsub/docs/replay-overview">Seek</a> operations, which
+ * allow you to manage message acknowledgments in bulk. That is, you can set the acknowledgment
+ * state of messages in an existing subscription to the state captured by a snapshot.
+ *
+ *
+ * try (TopicAdminClient topicAdminClient = TopicAdminClient.create()) {
+ * TopicName topic = TopicName.ofProjectTopicName("[PROJECT]", "[TOPIC]");
+ * for (String element : topicAdminClient.listTopicSnapshots(topic).iterateAll()) {
+ * // doThingsWith(element);
+ * }
+ * }
+ *
+ *
+ * @param topic Required. The name of the topic that snapshots are attached to. Format is
+ * `projects/{project}/topics/{topic}`.
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ /* package-private */ final ListTopicSnapshotsPagedResponse listTopicSnapshots(String topic) {
+ ListTopicSnapshotsRequest request =
+ ListTopicSnapshotsRequest.newBuilder().setTopic(topic).build();
+ return listTopicSnapshots(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD
+ /**
+ * Lists the names of the snapshots on this topic. Snapshots are used in <a
+ * href="https://cloud.google.com/pubsub/docs/replay-overview">Seek</a> operations, which
+ * allow you to manage message acknowledgments in bulk. That is, you can set the acknowledgment
+ * state of messages in an existing subscription to the state captured by a snapshot.
+ *
+ *
+ * try (TopicAdminClient topicAdminClient = TopicAdminClient.create()) {
+ * TopicName topic = TopicName.ofProjectTopicName("[PROJECT]", "[TOPIC]");
+ * for (String element : topicAdminClient.listTopicSnapshots(topic.toString()).iterateAll()) {
+ * // doThingsWith(element);
+ * }
+ * }
+ *
+ *
+ * @param request The request object containing all of the parameters for the API call.
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ /* package-private */ final ListTopicSnapshotsPagedResponse listTopicSnapshots(
+ ListTopicSnapshotsRequest request) {
+ return listTopicSnapshotsPagedCallable().call(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD
+ /**
+ * Lists the names of the snapshots on this topic. Snapshots are used in <a
+ * href="https://cloud.google.com/pubsub/docs/replay-overview">Seek</a> operations, which
+ * allow you to manage message acknowledgments in bulk. That is, you can set the acknowledgment
+ * state of messages in an existing subscription to the state captured by a snapshot.
+ *
+ *
+ * try (TopicAdminClient topicAdminClient = TopicAdminClient.create()) {
+ * TopicName topic = TopicName.ofProjectTopicName("[PROJECT]", "[TOPIC]");
+ * ListTopicSnapshotsRequest request = ListTopicSnapshotsRequest.newBuilder()
+ * .setTopic(topic.toString())
+ * .build();
+ * for (String element : topicAdminClient.listTopicSnapshots(request).iterateAll()) {
+ * // doThingsWith(element);
+ * }
+ * }
+ *
+ */
+ /* package-private */ final UnaryCallable<
+ ListTopicSnapshotsRequest, ListTopicSnapshotsPagedResponse>
+ listTopicSnapshotsPagedCallable() {
+ return stub.listTopicSnapshotsPagedCallable();
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD
+ /**
+ * Lists the names of the snapshots on this topic. Snapshots are used in <a
+ * href="https://cloud.google.com/pubsub/docs/replay-overview">Seek</a> operations, which
+ * allow you to manage message acknowledgments in bulk. That is, you can set the acknowledgment
+ * state of messages in an existing subscription to the state captured by a snapshot.
+ *
+ *
+ * try (TopicAdminClient topicAdminClient = TopicAdminClient.create()) {
+ * TopicName topic = TopicName.ofProjectTopicName("[PROJECT]", "[TOPIC]");
+ * ListTopicSnapshotsRequest request = ListTopicSnapshotsRequest.newBuilder()
+ * .setTopic(topic.toString())
+ * .build();
+ * ApiFuture<ListTopicSnapshotsPagedResponse> future = topicAdminClient.listTopicSnapshotsPagedCallable().futureCall(request);
+ * // Do something
+ * for (String element : future.get().iterateAll()) {
+ * // doThingsWith(element);
+ * }
+ * }
+ *
+ */
+ /* package-private */ final UnaryCallable
+ * try (TopicAdminClient topicAdminClient = TopicAdminClient.create()) {
+ * TopicName topic = TopicName.ofProjectTopicName("[PROJECT]", "[TOPIC]");
+ * ListTopicSnapshotsRequest request = ListTopicSnapshotsRequest.newBuilder()
+ * .setTopic(topic.toString())
+ * .build();
+ * while (true) {
+ * ListTopicSnapshotsResponse response = topicAdminClient.listTopicSnapshotsCallable().call(request);
+ * for (String element : response.getSnapshotsList()) {
+ * // doThingsWith(element);
+ * }
+ * String nextPageToken = response.getNextPageToken();
+ * if (!Strings.isNullOrEmpty(nextPageToken)) {
+ * request = request.toBuilder().setPageToken(nextPageToken).build();
+ * } else {
+ * break;
+ * }
+ * }
+ * }
+ *
* A URL locating the endpoint to which messages should be pushed.
- * For example, a Webhook endpoint might use "https://example.com/push".
+ * For example, a Webhook endpoint might use `https://example.com/push`.
*
*
* string push_endpoint = 1;
@@ -1163,7 +1163,7 @@ public java.lang.String getPushEndpoint() {
*
*
* A URL locating the endpoint to which messages should be pushed.
- * For example, a Webhook endpoint might use "https://example.com/push".
+ * For example, a Webhook endpoint might use `https://example.com/push`.
*
*
* string push_endpoint = 1;
@@ -1808,7 +1808,7 @@ public Builder clearAuthenticationMethod() {
*
*
* A URL locating the endpoint to which messages should be pushed.
- * For example, a Webhook endpoint might use "https://example.com/push".
+ * For example, a Webhook endpoint might use `https://example.com/push`.
*
*
* string push_endpoint = 1;
@@ -1831,7 +1831,7 @@ public java.lang.String getPushEndpoint() {
*
*
* A URL locating the endpoint to which messages should be pushed.
- * For example, a Webhook endpoint might use "https://example.com/push".
+ * For example, a Webhook endpoint might use `https://example.com/push`.
*
*
* string push_endpoint = 1;
@@ -1854,7 +1854,7 @@ public com.google.protobuf.ByteString getPushEndpointBytes() {
*
*
* A URL locating the endpoint to which messages should be pushed.
- * For example, a Webhook endpoint might use "https://example.com/push".
+ * For example, a Webhook endpoint might use `https://example.com/push`.
*
*
* string push_endpoint = 1;
@@ -1876,7 +1876,7 @@ public Builder setPushEndpoint(java.lang.String value) {
*
*
* A URL locating the endpoint to which messages should be pushed.
- * For example, a Webhook endpoint might use "https://example.com/push".
+ * For example, a Webhook endpoint might use `https://example.com/push`.
*
*
* string push_endpoint = 1;
@@ -1894,7 +1894,7 @@ public Builder clearPushEndpoint() {
*
*
* A URL locating the endpoint to which messages should be pushed.
- * For example, a Webhook endpoint might use "https://example.com/push".
+ * For example, a Webhook endpoint might use `https://example.com/push`.
*
*
* string push_endpoint = 1;
diff --git a/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/PushConfigOrBuilder.java b/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/PushConfigOrBuilder.java
index 873e0074a..091a066f9 100644
--- a/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/PushConfigOrBuilder.java
+++ b/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/PushConfigOrBuilder.java
@@ -28,7 +28,7 @@ public interface PushConfigOrBuilder
*
*
* A URL locating the endpoint to which messages should be pushed.
- * For example, a Webhook endpoint might use "https://example.com/push".
+ * For example, a Webhook endpoint might use `https://example.com/push`.
*
*
* string push_endpoint = 1;
@@ -41,7 +41,7 @@ public interface PushConfigOrBuilder
*
*
* A URL locating the endpoint to which messages should be pushed.
- * For example, a Webhook endpoint might use "https://example.com/push".
+ * For example, a Webhook endpoint might use `https://example.com/push`.
*
*
* string push_endpoint = 1;
diff --git a/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/ReceivedMessage.java b/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/ReceivedMessage.java
index b366d91da..298013f30 100644
--- a/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/ReceivedMessage.java
+++ b/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/ReceivedMessage.java
@@ -227,19 +227,18 @@ public com.google.pubsub.v1.PubsubMessageOrBuilder getMessageOrBuilder() {
*
*
*
- * Delivery attempt counter is 1 + (the sum of number of NACKs and number of
- * ack_deadline exceeds) for this message.
+ * The approximate number of times that Cloud Pub/Sub has attempted to deliver
+ * the associated message to a subscriber.
+ * More precisely, this is 1 + (number of NACKs) +
+ * (number of ack_deadline exceeds) for this message.
* A NACK is any call to ModifyAckDeadline with a 0 deadline. An ack_deadline
* exceeds event is whenever a message is not acknowledged within
* ack_deadline. Note that ack_deadline is initially
* Subscription.ackDeadlineSeconds, but may get extended automatically by
* the client library.
- * The first delivery of a given message will have this value as 1. The value
- * is calculated at best effort and is approximate.
+ * Upon the first delivery of a given message, `delivery_attempt` will have a
+ * value of 1. The value is calculated at best effort and is approximate.
* If a DeadLetterPolicy is not set on the subscription, this will be 0.
- * <b>EXPERIMENTAL:</b> This feature is part of a closed alpha release. This
- * API might be changed in backward-incompatible ways and is not recommended
- * for production use. It is not subject to any SLA or deprecation policy.
*
*
* int32 delivery_attempt = 3;
@@ -902,19 +901,18 @@ public com.google.pubsub.v1.PubsubMessageOrBuilder getMessageOrBuilder() {
*
*
*
- * Delivery attempt counter is 1 + (the sum of number of NACKs and number of
- * ack_deadline exceeds) for this message.
+ * The approximate number of times that Cloud Pub/Sub has attempted to deliver
+ * the associated message to a subscriber.
+ * More precisely, this is 1 + (number of NACKs) +
+ * (number of ack_deadline exceeds) for this message.
* A NACK is any call to ModifyAckDeadline with a 0 deadline. An ack_deadline
* exceeds event is whenever a message is not acknowledged within
* ack_deadline. Note that ack_deadline is initially
* Subscription.ackDeadlineSeconds, but may get extended automatically by
* the client library.
- * The first delivery of a given message will have this value as 1. The value
- * is calculated at best effort and is approximate.
+ * Upon the first delivery of a given message, `delivery_attempt` will have a
+ * value of 1. The value is calculated at best effort and is approximate.
* If a DeadLetterPolicy is not set on the subscription, this will be 0.
- * <b>EXPERIMENTAL:</b> This feature is part of a closed alpha release. This
- * API might be changed in backward-incompatible ways and is not recommended
- * for production use. It is not subject to any SLA or deprecation policy.
*
*
* int32 delivery_attempt = 3;
@@ -928,19 +926,18 @@ public int getDeliveryAttempt() {
*
*
*
- * Delivery attempt counter is 1 + (the sum of number of NACKs and number of
- * ack_deadline exceeds) for this message.
+ * The approximate number of times that Cloud Pub/Sub has attempted to deliver
+ * the associated message to a subscriber.
+ * More precisely, this is 1 + (number of NACKs) +
+ * (number of ack_deadline exceeds) for this message.
* A NACK is any call to ModifyAckDeadline with a 0 deadline. An ack_deadline
* exceeds event is whenever a message is not acknowledged within
* ack_deadline. Note that ack_deadline is initially
* Subscription.ackDeadlineSeconds, but may get extended automatically by
* the client library.
- * The first delivery of a given message will have this value as 1. The value
- * is calculated at best effort and is approximate.
+ * Upon the first delivery of a given message, `delivery_attempt` will have a
+ * value of 1. The value is calculated at best effort and is approximate.
* If a DeadLetterPolicy is not set on the subscription, this will be 0.
- * <b>EXPERIMENTAL:</b> This feature is part of a closed alpha release. This
- * API might be changed in backward-incompatible ways and is not recommended
- * for production use. It is not subject to any SLA or deprecation policy.
*
*
* int32 delivery_attempt = 3;
@@ -958,19 +955,18 @@ public Builder setDeliveryAttempt(int value) {
*
*
*
- * Delivery attempt counter is 1 + (the sum of number of NACKs and number of
- * ack_deadline exceeds) for this message.
+ * The approximate number of times that Cloud Pub/Sub has attempted to deliver
+ * the associated message to a subscriber.
+ * More precisely, this is 1 + (number of NACKs) +
+ * (number of ack_deadline exceeds) for this message.
* A NACK is any call to ModifyAckDeadline with a 0 deadline. An ack_deadline
* exceeds event is whenever a message is not acknowledged within
* ack_deadline. Note that ack_deadline is initially
* Subscription.ackDeadlineSeconds, but may get extended automatically by
* the client library.
- * The first delivery of a given message will have this value as 1. The value
- * is calculated at best effort and is approximate.
+ * Upon the first delivery of a given message, `delivery_attempt` will have a
+ * value of 1. The value is calculated at best effort and is approximate.
* If a DeadLetterPolicy is not set on the subscription, this will be 0.
- * <b>EXPERIMENTAL:</b> This feature is part of a closed alpha release. This
- * API might be changed in backward-incompatible ways and is not recommended
- * for production use. It is not subject to any SLA or deprecation policy.
*
*
* int32 delivery_attempt = 3;
diff --git a/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/ReceivedMessageOrBuilder.java b/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/ReceivedMessageOrBuilder.java
index eb54e43f1..805690b39 100644
--- a/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/ReceivedMessageOrBuilder.java
+++ b/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/ReceivedMessageOrBuilder.java
@@ -87,19 +87,18 @@ public interface ReceivedMessageOrBuilder
*
*
*
- * Delivery attempt counter is 1 + (the sum of number of NACKs and number of
- * ack_deadline exceeds) for this message.
+ * The approximate number of times that Cloud Pub/Sub has attempted to deliver
+ * the associated message to a subscriber.
+ * More precisely, this is 1 + (number of NACKs) +
+ * (number of ack_deadline exceeds) for this message.
* A NACK is any call to ModifyAckDeadline with a 0 deadline. An ack_deadline
* exceeds event is whenever a message is not acknowledged within
* ack_deadline. Note that ack_deadline is initially
* Subscription.ackDeadlineSeconds, but may get extended automatically by
* the client library.
- * The first delivery of a given message will have this value as 1. The value
- * is calculated at best effort and is approximate.
+ * Upon the first delivery of a given message, `delivery_attempt` will have a
+ * value of 1. The value is calculated at best effort and is approximate.
* If a DeadLetterPolicy is not set on the subscription, this will be 0.
- * <b>EXPERIMENTAL:</b> This feature is part of a closed alpha release. This
- * API might be changed in backward-incompatible ways and is not recommended
- * for production use. It is not subject to any SLA or deprecation policy.
*
*
* int32 delivery_attempt = 3;
diff --git a/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/Subscription.java b/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/Subscription.java
index c91b6d10f..64391376b 100644
--- a/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/Subscription.java
+++ b/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/Subscription.java
@@ -773,9 +773,6 @@ public com.google.protobuf.ByteString getFilterBytes() {
* parent project (i.e.,
* service-{project_number}@gcp-sa-pubsub.iam.gserviceaccount.com) must have
* permission to Acknowledge() messages on this subscription.
- * <b>EXPERIMENTAL:</b> This feature is part of a closed alpha release. This
- * API might be changed in backward-incompatible ways and is not recommended
- * for production use. It is not subject to any SLA or deprecation policy.
*
*
* .google.pubsub.v1.DeadLetterPolicy dead_letter_policy = 13;
@@ -796,9 +793,6 @@ public boolean hasDeadLetterPolicy() {
* parent project (i.e.,
* service-{project_number}@gcp-sa-pubsub.iam.gserviceaccount.com) must have
* permission to Acknowledge() messages on this subscription.
- * <b>EXPERIMENTAL:</b> This feature is part of a closed alpha release. This
- * API might be changed in backward-incompatible ways and is not recommended
- * for production use. It is not subject to any SLA or deprecation policy.
*
*
* .google.pubsub.v1.DeadLetterPolicy dead_letter_policy = 13;
@@ -821,9 +815,6 @@ public com.google.pubsub.v1.DeadLetterPolicy getDeadLetterPolicy() {
* parent project (i.e.,
* service-{project_number}@gcp-sa-pubsub.iam.gserviceaccount.com) must have
* permission to Acknowledge() messages on this subscription.
- * <b>EXPERIMENTAL:</b> This feature is part of a closed alpha release. This
- * API might be changed in backward-incompatible ways and is not recommended
- * for production use. It is not subject to any SLA or deprecation policy.
*
*
* .google.pubsub.v1.DeadLetterPolicy dead_letter_policy = 13;
@@ -2948,9 +2939,6 @@ public Builder setFilterBytes(com.google.protobuf.ByteString value) {
* parent project (i.e.,
* service-{project_number}@gcp-sa-pubsub.iam.gserviceaccount.com) must have
* permission to Acknowledge() messages on this subscription.
- * <b>EXPERIMENTAL:</b> This feature is part of a closed alpha release. This
- * API might be changed in backward-incompatible ways and is not recommended
- * for production use. It is not subject to any SLA or deprecation policy.
*
*
* .google.pubsub.v1.DeadLetterPolicy dead_letter_policy = 13;
@@ -2971,9 +2959,6 @@ public boolean hasDeadLetterPolicy() {
* parent project (i.e.,
* service-{project_number}@gcp-sa-pubsub.iam.gserviceaccount.com) must have
* permission to Acknowledge() messages on this subscription.
- * <b>EXPERIMENTAL:</b> This feature is part of a closed alpha release. This
- * API might be changed in backward-incompatible ways and is not recommended
- * for production use. It is not subject to any SLA or deprecation policy.
*
*
* .google.pubsub.v1.DeadLetterPolicy dead_letter_policy = 13;
@@ -3000,9 +2985,6 @@ public com.google.pubsub.v1.DeadLetterPolicy getDeadLetterPolicy() {
* parent project (i.e.,
* service-{project_number}@gcp-sa-pubsub.iam.gserviceaccount.com) must have
* permission to Acknowledge() messages on this subscription.
- * <b>EXPERIMENTAL:</b> This feature is part of a closed alpha release. This
- * API might be changed in backward-incompatible ways and is not recommended
- * for production use. It is not subject to any SLA or deprecation policy.
*
*
* .google.pubsub.v1.DeadLetterPolicy dead_letter_policy = 13;
@@ -3031,9 +3013,6 @@ public Builder setDeadLetterPolicy(com.google.pubsub.v1.DeadLetterPolicy value)
* parent project (i.e.,
* service-{project_number}@gcp-sa-pubsub.iam.gserviceaccount.com) must have
* permission to Acknowledge() messages on this subscription.
- * <b>EXPERIMENTAL:</b> This feature is part of a closed alpha release. This
- * API might be changed in backward-incompatible ways and is not recommended
- * for production use. It is not subject to any SLA or deprecation policy.
*
*
* .google.pubsub.v1.DeadLetterPolicy dead_letter_policy = 13;
@@ -3060,9 +3039,6 @@ public Builder setDeadLetterPolicy(
* parent project (i.e.,
* service-{project_number}@gcp-sa-pubsub.iam.gserviceaccount.com) must have
* permission to Acknowledge() messages on this subscription.
- * <b>EXPERIMENTAL:</b> This feature is part of a closed alpha release. This
- * API might be changed in backward-incompatible ways and is not recommended
- * for production use. It is not subject to any SLA or deprecation policy.
*
*
* .google.pubsub.v1.DeadLetterPolicy dead_letter_policy = 13;
@@ -3095,9 +3071,6 @@ public Builder mergeDeadLetterPolicy(com.google.pubsub.v1.DeadLetterPolicy value
* parent project (i.e.,
* service-{project_number}@gcp-sa-pubsub.iam.gserviceaccount.com) must have
* permission to Acknowledge() messages on this subscription.
- * <b>EXPERIMENTAL:</b> This feature is part of a closed alpha release. This
- * API might be changed in backward-incompatible ways and is not recommended
- * for production use. It is not subject to any SLA or deprecation policy.
*
*
* .google.pubsub.v1.DeadLetterPolicy dead_letter_policy = 13;
@@ -3124,9 +3097,6 @@ public Builder clearDeadLetterPolicy() {
* parent project (i.e.,
* service-{project_number}@gcp-sa-pubsub.iam.gserviceaccount.com) must have
* permission to Acknowledge() messages on this subscription.
- * <b>EXPERIMENTAL:</b> This feature is part of a closed alpha release. This
- * API might be changed in backward-incompatible ways and is not recommended
- * for production use. It is not subject to any SLA or deprecation policy.
*
*
* .google.pubsub.v1.DeadLetterPolicy dead_letter_policy = 13;
@@ -3147,9 +3117,6 @@ public com.google.pubsub.v1.DeadLetterPolicy.Builder getDeadLetterPolicyBuilder(
* parent project (i.e.,
* service-{project_number}@gcp-sa-pubsub.iam.gserviceaccount.com) must have
* permission to Acknowledge() messages on this subscription.
- * <b>EXPERIMENTAL:</b> This feature is part of a closed alpha release. This
- * API might be changed in backward-incompatible ways and is not recommended
- * for production use. It is not subject to any SLA or deprecation policy.
*
*
* .google.pubsub.v1.DeadLetterPolicy dead_letter_policy = 13;
@@ -3174,9 +3141,6 @@ public com.google.pubsub.v1.DeadLetterPolicyOrBuilder getDeadLetterPolicyOrBuild
* parent project (i.e.,
* service-{project_number}@gcp-sa-pubsub.iam.gserviceaccount.com) must have
* permission to Acknowledge() messages on this subscription.
- * <b>EXPERIMENTAL:</b> This feature is part of a closed alpha release. This
- * API might be changed in backward-incompatible ways and is not recommended
- * for production use. It is not subject to any SLA or deprecation policy.
*
*
* .google.pubsub.v1.DeadLetterPolicy dead_letter_policy = 13;
diff --git a/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/SubscriptionOrBuilder.java b/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/SubscriptionOrBuilder.java
index 0c1a6fe40..dd48671fb 100644
--- a/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/SubscriptionOrBuilder.java
+++ b/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/SubscriptionOrBuilder.java
@@ -406,9 +406,6 @@ public interface SubscriptionOrBuilder
* parent project (i.e.,
* service-{project_number}@gcp-sa-pubsub.iam.gserviceaccount.com) must have
* permission to Acknowledge() messages on this subscription.
- * <b>EXPERIMENTAL:</b> This feature is part of a closed alpha release. This
- * API might be changed in backward-incompatible ways and is not recommended
- * for production use. It is not subject to any SLA or deprecation policy.
*
*
* .google.pubsub.v1.DeadLetterPolicy dead_letter_policy = 13;
@@ -427,9 +424,6 @@ public interface SubscriptionOrBuilder
* parent project (i.e.,
* service-{project_number}@gcp-sa-pubsub.iam.gserviceaccount.com) must have
* permission to Acknowledge() messages on this subscription.
- * <b>EXPERIMENTAL:</b> This feature is part of a closed alpha release. This
- * API might be changed in backward-incompatible ways and is not recommended
- * for production use. It is not subject to any SLA or deprecation policy.
*
*
* .google.pubsub.v1.DeadLetterPolicy dead_letter_policy = 13;
@@ -448,9 +442,6 @@ public interface SubscriptionOrBuilder
* parent project (i.e.,
* service-{project_number}@gcp-sa-pubsub.iam.gserviceaccount.com) must have
* permission to Acknowledge() messages on this subscription.
- * <b>EXPERIMENTAL:</b> This feature is part of a closed alpha release. This
- * API might be changed in backward-incompatible ways and is not recommended
- * for production use. It is not subject to any SLA or deprecation policy.
*
*
* .google.pubsub.v1.DeadLetterPolicy dead_letter_policy = 13;
diff --git a/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/TopicName.java b/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/TopicName.java
index 09996bf5e..14d871ac5 100644
--- a/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/TopicName.java
+++ b/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/TopicName.java
@@ -22,8 +22,6 @@
import com.google.api.resourcenames.ResourceName;
import com.google.common.base.Preconditions;
import com.google.common.collect.ImmutableMap;
-import java.util.ArrayList;
-import java.util.List;
import java.util.Map;
import java.util.Objects;
@@ -119,28 +117,6 @@ public static TopicName parse(String formattedString) {
throw new ValidationException("JobName.parse: formattedString not in valid format");
}
- @BetaApi("The method will be renamed to parseList after subclasses of this class are removed.")
- public static List
* Required. Indicates which fields in the provided topic to update. Must be
* specified and non-empty. Note that if `update_mask` contains
- * "message_storage_policy" then the new value will be determined based on the
- * policy configured at the project or organization level. The
- * `message_storage_policy` must not be set in the `topic` provided above.
+ * "message_storage_policy" but the `message_storage_policy` is not set in
+ * the `topic` provided above, then the updated value is determined by the
+ * policy configured at the project or organization level.
*
*
* .google.protobuf.FieldMask update_mask = 2 [(.google.api.field_behavior) = REQUIRED];
@@ -201,9 +201,9 @@ public boolean hasUpdateMask() {
*
* Required. Indicates which fields in the provided topic to update. Must be
* specified and non-empty. Note that if `update_mask` contains
- * "message_storage_policy" then the new value will be determined based on the
- * policy configured at the project or organization level. The
- * `message_storage_policy` must not be set in the `topic` provided above.
+ * "message_storage_policy" but the `message_storage_policy` is not set in
+ * the `topic` provided above, then the updated value is determined by the
+ * policy configured at the project or organization level.
*
*
* .google.protobuf.FieldMask update_mask = 2 [(.google.api.field_behavior) = REQUIRED];
@@ -220,9 +220,9 @@ public com.google.protobuf.FieldMask getUpdateMask() {
*
* Required. Indicates which fields in the provided topic to update. Must be
* specified and non-empty. Note that if `update_mask` contains
- * "message_storage_policy" then the new value will be determined based on the
- * policy configured at the project or organization level. The
- * `message_storage_policy` must not be set in the `topic` provided above.
+ * "message_storage_policy" but the `message_storage_policy` is not set in
+ * the `topic` provided above, then the updated value is determined by the
+ * policy configured at the project or organization level.
*
*
* .google.protobuf.FieldMask update_mask = 2 [(.google.api.field_behavior) = REQUIRED];
@@ -776,9 +776,9 @@ public com.google.pubsub.v1.TopicOrBuilder getTopicOrBuilder() {
*
* Required. Indicates which fields in the provided topic to update. Must be
* specified and non-empty. Note that if `update_mask` contains
- * "message_storage_policy" then the new value will be determined based on the
- * policy configured at the project or organization level. The
- * `message_storage_policy` must not be set in the `topic` provided above.
+ * "message_storage_policy" but the `message_storage_policy` is not set in
+ * the `topic` provided above, then the updated value is determined by the
+ * policy configured at the project or organization level.
*
*
* .google.protobuf.FieldMask update_mask = 2 [(.google.api.field_behavior) = REQUIRED];
@@ -795,9 +795,9 @@ public boolean hasUpdateMask() {
*
* Required. Indicates which fields in the provided topic to update. Must be
* specified and non-empty. Note that if `update_mask` contains
- * "message_storage_policy" then the new value will be determined based on the
- * policy configured at the project or organization level. The
- * `message_storage_policy` must not be set in the `topic` provided above.
+ * "message_storage_policy" but the `message_storage_policy` is not set in
+ * the `topic` provided above, then the updated value is determined by the
+ * policy configured at the project or organization level.
*
*
* .google.protobuf.FieldMask update_mask = 2 [(.google.api.field_behavior) = REQUIRED];
@@ -820,9 +820,9 @@ public com.google.protobuf.FieldMask getUpdateMask() {
*
* Required. Indicates which fields in the provided topic to update. Must be
* specified and non-empty. Note that if `update_mask` contains
- * "message_storage_policy" then the new value will be determined based on the
- * policy configured at the project or organization level. The
- * `message_storage_policy` must not be set in the `topic` provided above.
+ * "message_storage_policy" but the `message_storage_policy` is not set in
+ * the `topic` provided above, then the updated value is determined by the
+ * policy configured at the project or organization level.
*
*
* .google.protobuf.FieldMask update_mask = 2 [(.google.api.field_behavior) = REQUIRED];
@@ -847,9 +847,9 @@ public Builder setUpdateMask(com.google.protobuf.FieldMask value) {
*
* Required. Indicates which fields in the provided topic to update. Must be
* specified and non-empty. Note that if `update_mask` contains
- * "message_storage_policy" then the new value will be determined based on the
- * policy configured at the project or organization level. The
- * `message_storage_policy` must not be set in the `topic` provided above.
+ * "message_storage_policy" but the `message_storage_policy` is not set in
+ * the `topic` provided above, then the updated value is determined by the
+ * policy configured at the project or organization level.
*
*
* .google.protobuf.FieldMask update_mask = 2 [(.google.api.field_behavior) = REQUIRED];
@@ -871,9 +871,9 @@ public Builder setUpdateMask(com.google.protobuf.FieldMask.Builder builderForVal
*
* Required. Indicates which fields in the provided topic to update. Must be
* specified and non-empty. Note that if `update_mask` contains
- * "message_storage_policy" then the new value will be determined based on the
- * policy configured at the project or organization level. The
- * `message_storage_policy` must not be set in the `topic` provided above.
+ * "message_storage_policy" but the `message_storage_policy` is not set in
+ * the `topic` provided above, then the updated value is determined by the
+ * policy configured at the project or organization level.
*
*
* .google.protobuf.FieldMask update_mask = 2 [(.google.api.field_behavior) = REQUIRED];
@@ -900,9 +900,9 @@ public Builder mergeUpdateMask(com.google.protobuf.FieldMask value) {
*
* Required. Indicates which fields in the provided topic to update. Must be
* specified and non-empty. Note that if `update_mask` contains
- * "message_storage_policy" then the new value will be determined based on the
- * policy configured at the project or organization level. The
- * `message_storage_policy` must not be set in the `topic` provided above.
+ * "message_storage_policy" but the `message_storage_policy` is not set in
+ * the `topic` provided above, then the updated value is determined by the
+ * policy configured at the project or organization level.
*
*
* .google.protobuf.FieldMask update_mask = 2 [(.google.api.field_behavior) = REQUIRED];
@@ -925,9 +925,9 @@ public Builder clearUpdateMask() {
*
* Required. Indicates which fields in the provided topic to update. Must be
* specified and non-empty. Note that if `update_mask` contains
- * "message_storage_policy" then the new value will be determined based on the
- * policy configured at the project or organization level. The
- * `message_storage_policy` must not be set in the `topic` provided above.
+ * "message_storage_policy" but the `message_storage_policy` is not set in
+ * the `topic` provided above, then the updated value is determined by the
+ * policy configured at the project or organization level.
*
*
* .google.protobuf.FieldMask update_mask = 2 [(.google.api.field_behavior) = REQUIRED];
@@ -944,9 +944,9 @@ public com.google.protobuf.FieldMask.Builder getUpdateMaskBuilder() {
*
* Required. Indicates which fields in the provided topic to update. Must be
* specified and non-empty. Note that if `update_mask` contains
- * "message_storage_policy" then the new value will be determined based on the
- * policy configured at the project or organization level. The
- * `message_storage_policy` must not be set in the `topic` provided above.
+ * "message_storage_policy" but the `message_storage_policy` is not set in
+ * the `topic` provided above, then the updated value is determined by the
+ * policy configured at the project or organization level.
*
*
* .google.protobuf.FieldMask update_mask = 2 [(.google.api.field_behavior) = REQUIRED];
@@ -967,9 +967,9 @@ public com.google.protobuf.FieldMaskOrBuilder getUpdateMaskOrBuilder() {
*
* Required. Indicates which fields in the provided topic to update. Must be
* specified and non-empty. Note that if `update_mask` contains
- * "message_storage_policy" then the new value will be determined based on the
- * policy configured at the project or organization level. The
- * `message_storage_policy` must not be set in the `topic` provided above.
+ * "message_storage_policy" but the `message_storage_policy` is not set in
+ * the `topic` provided above, then the updated value is determined by the
+ * policy configured at the project or organization level.
*
*
* .google.protobuf.FieldMask update_mask = 2 [(.google.api.field_behavior) = REQUIRED];
diff --git a/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/UpdateTopicRequestOrBuilder.java b/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/UpdateTopicRequestOrBuilder.java
index 257f0fdb8..c65735f57 100644
--- a/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/UpdateTopicRequestOrBuilder.java
+++ b/proto-google-cloud-pubsub-v1/src/main/java/com/google/pubsub/v1/UpdateTopicRequestOrBuilder.java
@@ -64,9 +64,9 @@ public interface UpdateTopicRequestOrBuilder
*
* Required. Indicates which fields in the provided topic to update. Must be
* specified and non-empty. Note that if `update_mask` contains
- * "message_storage_policy" then the new value will be determined based on the
- * policy configured at the project or organization level. The
- * `message_storage_policy` must not be set in the `topic` provided above.
+ * "message_storage_policy" but the `message_storage_policy` is not set in
+ * the `topic` provided above, then the updated value is determined by the
+ * policy configured at the project or organization level.
*
*
* .google.protobuf.FieldMask update_mask = 2 [(.google.api.field_behavior) = REQUIRED];
@@ -81,9 +81,9 @@ public interface UpdateTopicRequestOrBuilder
*
* Required. Indicates which fields in the provided topic to update. Must be
* specified and non-empty. Note that if `update_mask` contains
- * "message_storage_policy" then the new value will be determined based on the
- * policy configured at the project or organization level. The
- * `message_storage_policy` must not be set in the `topic` provided above.
+ * "message_storage_policy" but the `message_storage_policy` is not set in
+ * the `topic` provided above, then the updated value is determined by the
+ * policy configured at the project or organization level.
*
*
* .google.protobuf.FieldMask update_mask = 2 [(.google.api.field_behavior) = REQUIRED];
@@ -98,9 +98,9 @@ public interface UpdateTopicRequestOrBuilder
*
* Required. Indicates which fields in the provided topic to update. Must be
* specified and non-empty. Note that if `update_mask` contains
- * "message_storage_policy" then the new value will be determined based on the
- * policy configured at the project or organization level. The
- * `message_storage_policy` must not be set in the `topic` provided above.
+ * "message_storage_policy" but the `message_storage_policy` is not set in
+ * the `topic` provided above, then the updated value is determined by the
+ * policy configured at the project or organization level.
*
*
* .google.protobuf.FieldMask update_mask = 2 [(.google.api.field_behavior) = REQUIRED];
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 b49b30ed4..a42d03220 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
@@ -222,9 +222,9 @@ message UpdateTopicRequest {
// Required. Indicates which fields in the provided topic to update. Must be
// specified and non-empty. Note that if `update_mask` contains
- // "message_storage_policy" then the new value will be determined based on the
- // policy configured at the project or organization level. The
- // `message_storage_policy` must not be set in the `topic` provided above.
+ // "message_storage_policy" but the `message_storage_policy` is not set in
+ // the `topic` provided above, then the updated value is determined by the
+ // policy configured at the project or organization level.
google.protobuf.FieldMask update_mask = 2
[(google.api.field_behavior) = REQUIRED];
}
@@ -689,9 +689,6 @@ message Subscription {
// parent project (i.e.,
// service-{project_number}@gcp-sa-pubsub.iam.gserviceaccount.com) must have
// permission to Acknowledge() messages on this subscription.
- // EXPERIMENTAL: This feature is part of a closed alpha release. This
- // API might be changed in backward-incompatible ways and is not recommended
- // for production use. It is not subject to any SLA or deprecation policy.
DeadLetterPolicy dead_letter_policy = 13;
// A policy that specifies how Cloud Pub/Sub retries message delivery for this
@@ -796,7 +793,7 @@ message PushConfig {
}
// A URL locating the endpoint to which messages should be pushed.
- // For example, a Webhook endpoint might use "https://example.com/push".
+ // For example, a Webhook endpoint might use `https://example.com/push`.
string push_endpoint = 1;
// Endpoint configuration attributes that can be used to control different
@@ -842,8 +839,11 @@ message ReceivedMessage {
// The message.
PubsubMessage message = 2;
- // Delivery attempt counter is 1 + (the sum of number of NACKs and number of
- // ack_deadline exceeds) for this message.
+ // The approximate number of times that Cloud Pub/Sub has attempted to deliver
+ // the associated message to a subscriber.
+ //
+ // More precisely, this is 1 + (number of NACKs) +
+ // (number of ack_deadline exceeds) for this message.
//
// A NACK is any call to ModifyAckDeadline with a 0 deadline. An ack_deadline
// exceeds event is whenever a message is not acknowledged within
@@ -851,13 +851,10 @@ message ReceivedMessage {
// Subscription.ackDeadlineSeconds, but may get extended automatically by
// the client library.
//
- // The first delivery of a given message will have this value as 1. The value
- // is calculated at best effort and is approximate.
+ // Upon the first delivery of a given message, `delivery_attempt` will have a
+ // value of 1. The value is calculated at best effort and is approximate.
//
// If a DeadLetterPolicy is not set on the subscription, this will be 0.
- // EXPERIMENTAL: This feature is part of a closed alpha release. This
- // API might be changed in backward-incompatible ways and is not recommended
- // for production use. It is not subject to any SLA or deprecation policy.
int32 delivery_attempt = 3;
}
diff --git a/synth.metadata b/synth.metadata
index a508982a7..4effe7abd 100644
--- a/synth.metadata
+++ b/synth.metadata
@@ -3,23 +3,23 @@
{
"git": {
"name": ".",
- "remote": "git@github.com:googleapis/java-pubsub.git",
- "sha": "b4e0b77255ebb04eead8bf3e5c7be0fe76ac4c89"
+ "remote": "https://github.com/googleapis/java-pubsub.git",
+ "sha": "e1d285147accf85dc47417646388b8298f8c484e"
}
},
{
"git": {
"name": "googleapis",
"remote": "https://github.com/googleapis/googleapis.git",
- "sha": "b5e9b0b09cc15c263f07da92fa64db31b2e4dd07",
- "internalRef": "307068250"
+ "sha": "edd3b80fb770548d6ad780105f1782de6ff73ea0",
+ "internalRef": "311053644"
}
},
{
"git": {
"name": "synthtool",
"remote": "https://github.com/googleapis/synthtool.git",
- "sha": "f8a9933e5e98202b04ef427f28d1d79221190fa4"
+ "sha": "5b48b0716a36ca069db3038da7e205c87a22ed19"
}
}
],