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

Replace span.log with span.tag

This commit is contained in:
Johan Vandeweerd 2019-05-15 09:54:57 +02:00 committed by Tyler Benson
parent f5f8fe1c96
commit 35b924b397
1 changed files with 2 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
dd-java-agent/instrumentation/spring-webflux/src/main/java8/datadog/trace/instrumentation/springwebflux/client/SpringWebfluxHttpClientDecorator.java
View File

@ -3,8 +3,6 @@ package datadog.trace.instrumentation.springwebflux.client;
import datadog.trace.agent.decorator.HttpClientDecorator; import datadog.trace.agent.decorator.HttpClientDecorator;
import io.opentracing.Span; import io.opentracing.Span;
import java.net.URI; import java.net.URI;
import java.util.HashMap;
import java.util.Map;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.springframework.web.reactive.function.client.ClientRequest; import org.springframework.web.reactive.function.client.ClientRequest;
import org.springframework.web.reactive.function.client.ClientResponse; import org.springframework.web.reactive.function.client.ClientResponse;
@ -16,10 +14,8 @@ public class SpringWebfluxHttpClientDecorator
new SpringWebfluxHttpClientDecorator(); new SpringWebfluxHttpClientDecorator();
public void onCancel(final Span span) { public void onCancel(final Span span) {
final Map<String, Object> logs = new HashMap<>(2); span.setTag("event", "cancelled");
logs.put("event", "cancelled"); span.setTag("message", "The subscription was cancelled");
logs.put("message", "The subscription was cancelled");
span.log(logs);
} }
@Override @Override