Function main

cpp/examples/tracing_client.cpp:144–192

};

int main(int argc, char **argv) {
    try {
        std::string url("127.0.0.1:5672/examples");

        // 1. Initialize the exporter and the provider.
        // 2. Set the global trace provider.
        // 3. Call proton::initOpenTelemetryTracer().

        // Initialize otlp http Exporter
        opentelemetry::exporter::otlp::OtlpHttpExporterOptions options;
        options.url = "localhost:4318";
        auto exporter = std::unique_ptr<opentelemetry::sdk::trace::SpanExporter>(new opentelemetry::exporter::otlp::OtlpHttpExporter(options));

        // Set service-name
        auto resource_attributes = opentelemetry::sdk::resource::ResourceAttributes
        {
            {"service.name", "qpid-example-client"}
        };

        // Creation of the resource for associating it with telemetry
        auto resource = opentelemetry::sdk::resource::Resource::Create(resource_attributes);

        auto processor = std::unique_ptr<opentelemetry::sdk::trace::SpanProcessor>(
            new opentelemetry::sdk::trace::SimpleSpanProcessor(std::move(exporter)));
        provider = opentelemetry::nostd::shared_ptr<opentelemetry::trace::TracerProvider>(
            new opentelemetry::sdk::trace::TracerProvider(std::move(processor), resource));

        // Set the global trace provider
        opentelemetry::trace::Provider::SetTracerProvider(provider);

        // Enable tracing in proton cpp
        proton::initOpenTelemetryTracer();

        // Sending 2 messages to the server.
        std::vector<std::string> requests;
        requests.push_back("Two roads diverged in a wood.");
        requests.push_back("I took the one less traveled by.");

        client c(url, requests);

        proton::container(c).run();

        return 0;
    } catch (const std::exception& e) {
        std::cerr << e.what() << std::endl;
    }

    return 1;
}