Add x-b3-traceid inject to message header pass to other service

[voratham]

Add x-b3-traceid inject to message header pass to other service

Hi everyone, I have a problem about tracing on rabbitmq message by i have three service

┌──────────────────┐               ┌──────────────────┐           ┌───────────────┐
│                  │               │                  │           │               │
│    service a     │       queue   │    service b     │    queue  │   service c   │
│    (springboot)  │ ─────────────►│    (golang)      │ ─────────►│   (golang)    │
│                  │               │                  │           │               │
└──────────────────┘               └──────────────────┘           └───────────────┘




                                     ▼

My problem is service b cannot get traceID to connect from service a but i don't confident with code below

        Tracer trace = tracer.tracerBuilder("rabbitmq").build();
        Span span = trace.spanBuilder("rabbitmq-process").startSpan();
        
        CorrelationData correlationData = new CorrelationData();

        long generateCreatedTime = System.nanoTime();
        correlationData.setId("12345678");
        rabbitTemplate.convertAndSend(
                "test",
                "created",
                "testing from dream",
                m -> {
                    m.getMessageProperties().setHeader("X-B3-TraceId", span.getSpanContext().getTraceId());
                    m.getMessageProperties().setHeader("X-B3-SpanId", span.getSpanContext().getSpanId());
                    if (span.getSpanContext().isSampled()){
                        m.getMessageProperties().setHeader("X-B3-Sampled",1);
                    }
                    m.getMessageProperties().setHeader("x-timestamp", generateCreatedTime);
                    return m;
                },
                correlationData
        );

[jkwatson]

I'm not sure what your problem might be, but I do recommend using our provided B3 propagator for this functionality, rather than rebuilding it. You can find a link to the propagators in our documentation: https://github.com/open-telemetry/opentelemetry-java#api-extensions.

[voratham]

Thankyou @jkwatson I can problem solve

[srikanthinu]

@voratham what was the fix? we have similar issue now tracid is not propagating b/w services (Graphql in nodejs to Java Microservices)