Function main

pubsub-open-telemetry/blocking_publisher.cc:60–87

}  // namespace

int main(int argc, char* argv[]) try {
  auto args = ParseArguments(argc, argv);
  if (args.project_id.empty() && args.topic_id.empty()) {
    return 1;
  }
  std::cout << "Using project `" << args.project_id << "` and topic `"
            << args.topic_id << "`\n";

  // Automatically call `Cleanup()` before returning from `main()`.
  std::shared_ptr<void> cleanup(nullptr, [](void*) { Cleanup(); });

  ConfigureCloudTraceTracer(args);

  auto blocking_publisher = pubsub::BlockingPublisher(
      pubsub::MakeBlockingPublisherConnection(args.publisher_options));

  auto id = blocking_publisher.Publish(
      pubsub::Topic(args.project_id, args.topic_id),
      pubsub::MessageBuilder().SetData("Hello!").Build());

  if (!id) throw std::move(id).status();
  std::cout << "Sent message with id: " << *id << "\n";

  return 0;
} catch (google::cloud::Status const& status) {
  std::cerr << "google::cloud::Status thrown: " << status << "\n";
  return 1;
}