Skip to content

Commit 883a163

Browse files
committed
converted tests green
1 parent 17d9ec9 commit 883a163

File tree

10 files changed

+224
-655
lines changed

10 files changed

+224
-655
lines changed

instrumentation/aws-sdk/aws-sdk-2.2/javaagent/src/test/groovy/Aws2SqsSuppressReceiveSpansTest.groovy

Lines changed: 0 additions & 29 deletions
This file was deleted.

instrumentation/aws-sdk/aws-sdk-2.2/javaagent/src/test/java/io/opentelemetry/javaagent/instrumentation/awssdk/v2_2/Aws2SqsSuppressReceiveSpansTest.java

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,8 @@
1+
/*
2+
* Copyright The OpenTelemetry Authors
3+
* SPDX-License-Identifier: Apache-2.0
4+
*/
5+
16
package io.opentelemetry.javaagent.instrumentation.awssdk.v2_2;
27

38
import io.opentelemetry.instrumentation.awssdk.v2_2.AbstractAws2SqsSuppressReceiveSpansTest;
Original file line numberDiff line numberDiff line change
@@ -1,26 +1,23 @@
1+
/*
2+
* Copyright The OpenTelemetry Authors
3+
* SPDX-License-Identifier: Apache-2.0
4+
*/
5+
16
package io.opentelemetry.instrumentation.awssdk.v2_2;
27

3-
import org.junit.jupiter.api.BeforeAll;
8+
import static org.assertj.core.api.Assertions.assertThat;
9+
10+
import java.net.URISyntaxException;
411
import org.junit.jupiter.api.Test;
512
import software.amazon.awssdk.core.client.config.ClientOverrideConfiguration;
613
import software.amazon.awssdk.services.sqs.SqsClient;
714
import software.amazon.awssdk.services.sqs.SqsClientBuilder;
815
import software.amazon.awssdk.services.sqs.model.ReceiveMessageResponse;
9-
import java.net.URISyntaxException;
10-
11-
import static org.assertj.core.api.Assertions.assertThat;
1216

1317
class Aws2SqsSuppressReceiveSpansDefaultPropagatorTest extends Aws2SqsSuppressReceiveSpansTest {
1418

15-
@BeforeAll
16-
static void setup() {
17-
AwsSdkTelemetryBuilder telemetryBuilder = AwsSdkTelemetry.builder(testing.getOpenTelemetry())
18-
.setCaptureExperimentalSpanAttributes(true);
19-
configure(telemetryBuilder);
20-
telemetry = telemetryBuilder.build();
21-
}
22-
23-
static void configure(AwsSdkTelemetryBuilder telemetryBuilder) {}
19+
@Override
20+
protected void configure(AwsSdkTelemetryBuilder telemetryBuilder) {}
2421

2522
@Override
2623
boolean isSqsAttributeInjectionEnabled() {
@@ -31,10 +28,11 @@ boolean isSqsAttributeInjectionEnabled() {
3128
void testDuplicateTracingInterceptor() throws URISyntaxException {
3229
SqsClientBuilder builder = SqsClient.builder();
3330
configureSdkClient(builder);
34-
ClientOverrideConfiguration overrideConfiguration = ClientOverrideConfiguration.builder()
35-
.addExecutionInterceptor(telemetry.newExecutionInterceptor())
36-
.addExecutionInterceptor(telemetry.newExecutionInterceptor())
37-
.build();
31+
ClientOverrideConfiguration overrideConfiguration =
32+
ClientOverrideConfiguration.builder()
33+
.addExecutionInterceptor(telemetry.newExecutionInterceptor())
34+
.addExecutionInterceptor(telemetry.newExecutionInterceptor())
35+
.build();
3836
builder.overrideConfiguration(overrideConfiguration);
3937
SqsClient client = configureSqsClient(builder.build());
4038

@@ -45,6 +43,6 @@ void testDuplicateTracingInterceptor() throws URISyntaxException {
4543
assertThat(response.messages().size()).isEqualTo(1);
4644
response.messages().forEach(message -> getTesting().runWithSpan("process child", () -> {}));
4745

48-
assertSqsTraces(true, false);
46+
assertSqsTraces(false, false);
4947
}
5048
}

instrumentation/aws-sdk/aws-sdk-2.2/library/src/test/java/io/opentelemetry/instrumentation/awssdk/v2_2/Aws2SqsSuppressReceiveSpansTest.java

Lines changed: 21 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,28 +1,45 @@
1+
/*
2+
* Copyright The OpenTelemetry Authors
3+
* SPDX-License-Identifier: Apache-2.0
4+
*/
5+
16
package io.opentelemetry.instrumentation.awssdk.v2_2;
27

38
import io.opentelemetry.instrumentation.testing.junit.InstrumentationExtension;
49
import io.opentelemetry.instrumentation.testing.junit.LibraryInstrumentationExtension;
10+
import org.junit.jupiter.api.BeforeEach;
511
import org.junit.jupiter.api.extension.RegisterExtension;
612
import software.amazon.awssdk.core.client.config.ClientOverrideConfiguration;
713
import software.amazon.awssdk.services.sqs.SqsAsyncClient;
814
import software.amazon.awssdk.services.sqs.SqsClient;
915

10-
public abstract class Aws2SqsSuppressReceiveSpansTest extends AbstractAws2SqsSuppressReceiveSpansTest {
16+
public abstract class Aws2SqsSuppressReceiveSpansTest
17+
extends AbstractAws2SqsSuppressReceiveSpansTest {
1118
@RegisterExtension
1219
static final InstrumentationExtension testing = LibraryInstrumentationExtension.create();
1320

21+
@BeforeEach
22+
void setup() {
23+
AwsSdkTelemetryBuilder telemetryBuilder =
24+
AwsSdkTelemetry.builder(getTesting().getOpenTelemetry())
25+
.setCaptureExperimentalSpanAttributes(true);
26+
configure(telemetryBuilder);
27+
telemetry = telemetryBuilder.build();
28+
}
29+
1430
@Override
1531
protected InstrumentationExtension getTesting() {
1632
return testing;
1733
}
1834

19-
protected static AwsSdkTelemetry telemetry;
35+
protected abstract void configure(AwsSdkTelemetryBuilder telemetryBuilder);
36+
37+
protected AwsSdkTelemetry telemetry;
2038

2139
@Override
2240
protected ClientOverrideConfiguration.Builder createOverrideConfigurationBuilder() {
2341
return ClientOverrideConfiguration.builder()
24-
.addExecutionInterceptor(
25-
telemetry.newExecutionInterceptor());
42+
.addExecutionInterceptor(telemetry.newExecutionInterceptor());
2643
}
2744

2845
@Override

instrumentation/aws-sdk/aws-sdk-2.2/library/src/test/java/io/opentelemetry/instrumentation/awssdk/v2_2/Aws2SqsSuppressReceiveSpansW3CPropagatorAndXrayPropagatorTest.java

Lines changed: 15 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -1,20 +1,21 @@
1-
package io.opentelemetry.instrumentation.awssdk.v2_2;
1+
/*
2+
* Copyright The OpenTelemetry Authors
3+
* SPDX-License-Identifier: Apache-2.0
4+
*/
25

3-
import org.junit.jupiter.api.BeforeAll;
6+
package io.opentelemetry.instrumentation.awssdk.v2_2;
47

5-
/** We want to test the combination of W3C + Xray, as that's what you'll get in prod if you enable W3C. */
6-
class Aws2SqsSuppressReceiveSpansW3CPropagatorAndXrayPropagatorTest extends Aws2SqsSuppressReceiveSpansTest {
8+
/**
9+
* We want to test the combination of W3C + Xray, as that's what you'll get in prod if you enable
10+
* W3C.
11+
*/
12+
class Aws2SqsSuppressReceiveSpansW3CPropagatorAndXrayPropagatorTest
13+
extends Aws2SqsSuppressReceiveSpansTest {
714

8-
@BeforeAll
9-
static void setup() {
10-
AwsSdkTelemetryBuilder telemetryBuilder = AwsSdkTelemetry.builder(testing.getOpenTelemetry())
11-
.setCaptureExperimentalSpanAttributes(true);
12-
configure(telemetryBuilder);
13-
telemetry = telemetryBuilder.build();
14-
}
15-
16-
static void configure(AwsSdkTelemetryBuilder telemetryBuilder) {
17-
telemetryBuilder.setUseConfiguredPropagatorForMessaging(isSqsAttributeInjectionEnabled()); // Difference to main test
15+
@Override
16+
protected void configure(AwsSdkTelemetryBuilder telemetryBuilder) {
17+
telemetryBuilder.setUseConfiguredPropagatorForMessaging(
18+
isSqsAttributeInjectionEnabled()); // Difference to main test
1819
}
1920

2021
@Override

instrumentation/aws-sdk/aws-sdk-2.2/library/src/test/java/io/opentelemetry/instrumentation/awssdk/v2_2/Aws2SqsSuppressReceiveSpansW3CPropagatorTest.java

Lines changed: 11 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,10 +1,18 @@
1+
/*
2+
* Copyright The OpenTelemetry Authors
3+
* SPDX-License-Identifier: Apache-2.0
4+
*/
5+
16
package io.opentelemetry.instrumentation.awssdk.v2_2;
27

38
class Aws2SqsSuppressReceiveSpansW3CPropagatorTest extends Aws2SqsSuppressReceiveSpansTest {
49
@Override
5-
void configure(AwsSdkTelemetryBuilder telemetryBuilder) {
6-
telemetryBuilder.setUseConfiguredPropagatorForMessaging(isSqsAttributeInjectionEnabled()) // Difference to main test
7-
.setUseXrayPropagator(isXrayInjectionEnabled()); // Disable to confirm messaging propagator actually works
10+
protected void configure(AwsSdkTelemetryBuilder telemetryBuilder) {
11+
telemetryBuilder
12+
.setUseConfiguredPropagatorForMessaging(
13+
isSqsAttributeInjectionEnabled()) // Difference to main test
14+
.setUseXrayPropagator(
15+
isXrayInjectionEnabled()); // Disable to confirm messaging propagator actually works
816
}
917

1018
@Override

0 commit comments

Comments
 (0)