Add missing sample and fix references

googleapis · Oct 17, 2022 · a4765c5 · a4765c5
1 parent 641f873
commit a4765c5
Show file tree

Hide file tree

Showing 2 changed files with 27 additions and 2 deletions.
diff --git a/google/cloud/pubsub/blocking_publisher.h b/google/cloud/pubsub/blocking_publisher.h
@@ -98,10 +98,10 @@ class BlockingPublisher {
    * by changing the retry policy, please see the example below.
    *
    * @par Example
-   * @snippet samples.cc blocking-publish
+   * @snippet blocking_samples.cc blocking-publish
    *
    * @par Example
-   * @snippet samples.cc blocking-publish-no-retry
+   * @snippet blocking_samples.cc blocking-publish-no-retry
    *
    * @return On success, the server-assigned ID of the message. IDs are
    *     guaranteed to be unique within the topic.

diff --git a/google/cloud/pubsub/samples/blocking_samples.cc b/google/cloud/pubsub/samples/blocking_samples.cc
@@ -44,6 +44,30 @@ void BlockingPublish(std::vector<std::string> const& argv) {
   (argv.at(0), argv.at(1));
 }
 
+void BlockingPublishNoRetry(std::vector<std::string> const& argv) {
+  namespace examples = ::google::cloud::testing_util;
+  if (argv.size() != 2) {
+    throw examples::Usage{"blocking-publish-no-retry <project-id> <topic-id>"};
+  }
+  //! [blocking-publish-no-retry]
+  namespace pubsub = ::google::cloud::pubsub;
+  [](std::string project_id, std::string topic_id) {
+    auto topic = pubsub::Topic(std::move(project_id), std::move(topic_id));
+    auto publisher =
+        pubsub::BlockingPublisher(pubsub::MakeBlockingPublisherConnection());
+    auto id = publisher.Publish(
+        topic, pubsub::MessageBuilder().SetData("Hello World!").Build(),
+        google::cloud::Options{}.set<pubsub::RetryPolicyOption>(
+            pubsub::LimitedErrorCountRetryPolicy(/*maximum_failures=*/0)
+                .clone()));
+    if (!id) return;  // Without retries, errors are likely.
+    std::cout << "Hello World successfully published on topic "
+              << topic.FullName() << " with id " << *id << "\n";
+  }
+  //! [blocking-publish-no-retry]
+  (argv.at(0), argv.at(1));
+}
+
 void AutoRun(std::vector<std::string> const& argv) {
   namespace examples = ::google::cloud::testing_util;
 
@@ -81,6 +105,7 @@ int main(int argc, char* argv[]) {  // NOLINT(bugprone-exception-escape)
 
   Example example({
       {"blocking-publish", BlockingPublish},
+      {"blocking-publish-no-retry", BlockingPublishNoRetry},
       {"auto", AutoRun},
   });
   return example.Run(argc, argv);