Merge branch 'tr/setup' into tr/review

vibinex · Sep 18, 2023 · c9bca44 · c9bca44
2 parents ab1696f + 393b8e2
commit c9bca44
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/vibi-dpu/src/pubsub/listener.rs b/vibi-dpu/src/pubsub/listener.rs
@@ -86,7 +86,11 @@ async fn setup_subscription(keypath: &str, topicname: &str) -> Subscription{
         ..Default::default()
     };
     let subscription_name = format!("{topicname}-sub");
-    let subscription = client.subscription(&subscriptionname);
+    let subscription = client.subscription(&subscription_name);
+    let subconfig = SubscriptionConfig {
+        enable_message_ordering: true,
+        ..Default::default()
+    };
     if !subscription.exists(None).await.expect("Unable to get subscription information") {
         subscription.create(
             topic.fully_qualified_name(), subconfig, None)