bool-dev
diff --git a/‎pubsub/google/cloud/pubsub_v1/gapic/subscriber_client.py‎
Lines changed: 9 additions & 0 deletions b/‎pubsub/google/cloud/pubsub_v1/gapic/subscriber_client.py‎
Lines changed: 9 additions & 0 deletions
diff --git a/‎pubsub/google/cloud/pubsub_v1/proto/pubsub.proto‎
Lines changed: 18 additions & 0 deletions b/‎pubsub/google/cloud/pubsub_v1/proto/pubsub.proto‎
Lines changed: 18 additions & 0 deletions
@@ -224,6 +224,7 @@ def create_subscription(
         retain_acked_messages=None,
         message_retention_duration=None,
         labels=None,
+        enable_message_ordering=None,
         expiration_policy=None,
         retry=google.api_core.gapic_v1.method.DEFAULT,
         timeout=google.api_core.gapic_v1.method.DEFAULT,
@@ -309,6 +310,13 @@ def create_subscription(
                 message :class:`~google.cloud.pubsub_v1.types.Duration`
             labels (dict[str -> str]): See <a href="https://cloud.google.com/pubsub/docs/labels"> Creating and
                 managing labels</a>.
+            enable_message_ordering (bool): If true, messages published with the same ``ordering_key`` in
+                ``PubsubMessage`` will be delivered to the subscribers in the order in
+                which they are received by the Pub/Sub system. Otherwise, they may be
+                delivered in any order. 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.
             expiration_policy (Union[dict, ~google.cloud.pubsub_v1.types.ExpirationPolicy]): A policy that specifies the conditions for this subscription's
                 expiration. A subscription is considered active as long as any connected
                 subscriber is successfully consuming messages from the subscription or
@@ -359,6 +367,7 @@ def create_subscription(
             retain_acked_messages=retain_acked_messages,
             message_retention_duration=message_retention_duration,
             labels=labels,
+            enable_message_ordering=enable_message_ordering,
             expiration_policy=expiration_policy,
         )
         return self._inner_api_calls["create_subscription"](
 
@@ -406,6 +406,15 @@ message PubsubMessage {
   // it receives the `Publish` call. It must not be populated by the
   // publisher in a `Publish` call.
   google.protobuf.Timestamp publish_time = 4;
+
+  // Identifies related messages for which publish order should be respected.
+  // If a `Subscription` has `enable_message_ordering` set to `true`, messages
+  // published with the same `ordering_key` value will be delivered to
+  // subscribers in the order in which they are received by the Pub/Sub system.
+  // <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.
+  string ordering_key = 5;
 }
 
 // Request for the GetTopic method.
@@ -607,6 +616,15 @@ message Subscription {
   // managing labels</a>.
   map<string, string> labels = 9;
 
+  // If true, messages published with the same `ordering_key` in `PubsubMessage`
+  // will be delivered to the subscribers in the order in which they
+  // are received by the Pub/Sub system. Otherwise, they may be delivered in
+  // any order.
+  // <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.
+  bool enable_message_ordering = 10;
+
   // A policy that specifies the conditions for this subscription's expiration.
   // A subscription is considered active as long as any connected subscriber is
   // successfully consuming messages from the subscription or is issuing