open-telemetry
/
opentelemetry-java-instrumentation
mirror of https://github.com/open-telemetry/opentelemetry-java-instrumentation.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix dubbo trace/span cross-process propagation (#3442) 

* fix(instrument): fix dubbo client trace inject adapter.

* fix(instrument): fix dubbo client trace inject adapter.
This commit is contained in:
zmapleshine 2021-06-30 23:47:46 +08:00 committed by GitHub
parent 00b1b07684
commit bbd33115d1
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
instrumentation/apache-dubbo-2.7/library/src/main/java/io/opentelemetry/instrumentation/apachedubbo/v2_7/DubboInjectAdapter.java
View File

@ -6,14 +6,14 @@
package io.opentelemetry.instrumentation.apachedubbo.v2_7; package io.opentelemetry.instrumentation.apachedubbo.v2_7;
import io.opentelemetry.context.propagation.TextMapSetter; import io.opentelemetry.context.propagation.TextMapSetter;
import org.apache.dubbo.rpc.RpcInvocation; import org.apache.dubbo.rpc.RpcContext;
class DubboInjectAdapter implements TextMapSetter<RpcInvocation> { class DubboInjectAdapter implements TextMapSetter<RpcContext> {
static final DubboInjectAdapter SETTER = new DubboInjectAdapter(); static final DubboInjectAdapter SETTER = new DubboInjectAdapter();
@Override @Override
public void set(RpcInvocation rpcInvocation, String key, String value) { public void set(RpcContext rpcContext, String key, String value) {
rpcInvocation.setAttachment(key, value); rpcContext.setAttachment(key, value);
} }
} }

2
instrumentation/apache-dubbo-2.7/library/src/main/java/io/opentelemetry/instrumentation/apachedubbo/v2_7/OpenTelemetryFilter.java
View File

@ -40,7 +40,7 @@ public class OpenTelemetryFilter implements Filter {
final Context context; final Context context;
if (kind.equals(CLIENT)) { if (kind.equals(CLIENT)) {
context = tracer.startClientSpan(interfaceName, methodName); context = tracer.startClientSpan(interfaceName, methodName);
tracer.inject(context, (RpcInvocation) invocation, DubboInjectAdapter.SETTER); tracer.inject(context, rpcContext, DubboInjectAdapter.SETTER);
} else { } else {
context = tracer.startServerSpan(interfaceName, methodName, (RpcInvocation) invocation); context = tracer.startServerSpan(interfaceName, methodName, (RpcInvocation) invocation);
} }