|
19 | 19 | import io.opentelemetry.instrumentation.api.incubator.semconv.messaging.MessageOperation; |
20 | 20 | import io.opentelemetry.instrumentation.api.incubator.semconv.messaging.MessagingAttributesExtractor; |
21 | 21 | import io.opentelemetry.instrumentation.api.incubator.semconv.messaging.MessagingAttributesGetter; |
22 | | -import io.opentelemetry.instrumentation.api.incubator.semconv.messaging.MessagingNetworkAttributesExtractor; |
23 | 22 | import io.opentelemetry.instrumentation.api.incubator.semconv.messaging.MessagingSpanNameExtractor; |
24 | 23 | import io.opentelemetry.instrumentation.api.incubator.semconv.rpc.RpcClientAttributesExtractor; |
25 | 24 | import io.opentelemetry.instrumentation.api.instrumenter.AttributesExtractor; |
@@ -47,9 +46,6 @@ final class AwsSdkInstrumenterFactory { |
47 | 46 | private static final AwsSdkAttributesExtractor sdkAttributesExtractor = |
48 | 47 | new AwsSdkAttributesExtractor(); |
49 | 48 | private static final SnsAttributesExtractor snsAttributesExtractor = new SnsAttributesExtractor(); |
50 | | - private static final MessagingNetworkAttributesExtractor<Request<?>, Response<?>> |
51 | | - messagingNetworkAttributesExtractor = |
52 | | - MessagingNetworkAttributesExtractor.create(SqsAttributesGetter.INSTANCE); |
53 | 49 |
|
54 | 50 | private static final List<AttributesExtractor<Request<?>, Response<?>>> |
55 | 51 | defaultAttributesExtractors = createAttributesExtractors(false); |
@@ -81,8 +77,7 @@ private static List<AttributesExtractor<Request<?>, Response<?>>> createAttribut |
81 | 77 | httpAttributesExtractor, |
82 | 78 | rpcAttributesExtractor, |
83 | 79 | snsAttributesExtractor, |
84 | | - sdkAttributesExtractor, |
85 | | - messagingNetworkAttributesExtractor)); |
| 80 | + sdkAttributesExtractor)); |
86 | 81 | if (includeExperimental) { |
87 | 82 | extractors.add(experimentalAttributesExtractor); |
88 | 83 | } |
|
0 commit comments