Skip to content

Commit

Permalink
Chore: replaced bean to the end of the file & removed unused imports
Browse files Browse the repository at this point in the history
  • Loading branch information
ricklue committed Aug 28, 2024
1 parent 488db75 commit f1d4eb5
Show file tree
Hide file tree
Showing 2 changed files with 26 additions and 29 deletions.
52 changes: 26 additions & 26 deletions src/main/java/nl/nn/testtool/Config.java
Original file line number Diff line number Diff line change
Expand Up @@ -113,32 +113,6 @@
@Lazy // Lazy init singleton beans (prototype beans are already loaded on demand)
@Configuration
public class Config {
@Bean
OpenTelemetry openTelemetry(@Qualifier("openTelemetryCollector") String openTelemetryCollector) {
Resource resource = Resource.getDefault().toBuilder().put(ServiceAttributes.SERVICE_NAME, "ladybug").put(ServiceAttributes.SERVICE_VERSION, "1.0.0").build();
SdkTracerProvider sdkTracerProvider;
if (openTelemetryCollector.contains("9411")) {
sdkTracerProvider = SdkTracerProvider.builder()
.addSpanProcessor(BatchSpanProcessor.builder(ZipkinSpanExporter.builder().setEndpoint(openTelemetryCollector).build()).build())
.setResource(resource)
.build();
} else if (openTelemetryCollector.equals("jaeger")) {
sdkTracerProvider = SdkTracerProvider.builder()
.addSpanProcessor(BatchSpanProcessor.builder(OtlpGrpcSpanExporter.builder().build()).build())
.setResource(resource)
.build();
} else {
return OpenTelemetry.noop();
}

OpenTelemetry openTelemetry = OpenTelemetrySdk.builder()
.setTracerProvider(sdkTracerProvider)
.setPropagators(ContextPropagators.create(TextMapPropagator.composite(W3CTraceContextPropagator.getInstance(), W3CBaggagePropagator.getInstance())))
.buildAndRegisterGlobal();

return openTelemetry;
}

@Bean
@Scope("prototype") // Echo2Application needs to be unique per user (not per JVM)
Echo2Application echo2Application() {
Expand Down Expand Up @@ -327,4 +301,30 @@ String openTelemetryCollector() {
return "";
}

@Bean
OpenTelemetry openTelemetry(@Qualifier("openTelemetryCollector") String openTelemetryCollector) {
Resource resource = Resource.getDefault().toBuilder().put(ServiceAttributes.SERVICE_NAME, "ladybug").put(ServiceAttributes.SERVICE_VERSION, "1.0.0").build();
SdkTracerProvider sdkTracerProvider;
if (openTelemetryCollector.contains("9411")) {
sdkTracerProvider = SdkTracerProvider.builder()
.addSpanProcessor(BatchSpanProcessor.builder(ZipkinSpanExporter.builder().setEndpoint(openTelemetryCollector).build()).build())
.setResource(resource)
.build();
} else if (openTelemetryCollector.equals("jaeger")) {
sdkTracerProvider = SdkTracerProvider.builder()
.addSpanProcessor(BatchSpanProcessor.builder(OtlpGrpcSpanExporter.builder().build()).build())
.setResource(resource)
.build();
} else {
return OpenTelemetry.noop();
}

OpenTelemetry openTelemetry = OpenTelemetrySdk.builder()
.setTracerProvider(sdkTracerProvider)
.setPropagators(ContextPropagators.create(TextMapPropagator.composite(W3CTraceContextPropagator.getInstance(), W3CBaggagePropagator.getInstance())))
.buildAndRegisterGlobal();

return openTelemetry;
}

}
3 changes: 0 additions & 3 deletions src/main/java/nl/nn/testtool/Report.java
Original file line number Diff line number Diff line change
Expand Up @@ -30,10 +30,8 @@
import java.util.Scanner;
import java.util.Set;

import io.opentelemetry.api.OpenTelemetry;
import io.opentelemetry.api.trace.Span;
import io.opentelemetry.api.trace.SpanBuilder;
import io.opentelemetry.api.trace.Tracer;
import io.opentelemetry.context.Context;
import org.apache.commons.lang3.NotImplementedException;
import org.apache.commons.lang3.StringUtils;
Expand All @@ -52,7 +50,6 @@
import nl.nn.testtool.util.CsvUtil;
import nl.nn.testtool.util.EscapeUtil;
import nl.nn.testtool.util.XmlUtil;
import org.springframework.beans.factory.annotation.Autowired;

/**
* @author Jaco de Groot
Expand Down

0 comments on commit f1d4eb5

Please sign in to comment.