up

Azure · Sep 17, 2024 · f11ed76 · f11ed76
1 parent de349f4
commit f11ed76
Showing 1 changed file with 7 additions and 7 deletions.
diff --git a/...saging-eventhubs/src/test/java/com/azure/messaging/eventhubs/TracingIntegrationTests.java b/...saging-eventhubs/src/test/java/com/azure/messaging/eventhubs/TracingIntegrationTests.java
@@ -31,6 +31,7 @@
 import io.opentelemetry.sdk.trace.SpanProcessor;
 import io.opentelemetry.sdk.trace.data.LinkData;
 import io.opentelemetry.sdk.trace.data.SpanData;
+import org.junit.jupiter.api.Disabled;
 import org.junit.jupiter.api.Test;
 import org.junit.jupiter.api.parallel.Execution;
 import org.junit.jupiter.api.parallel.ExecutionMode;
@@ -67,14 +68,14 @@
 
 @Isolated("Sets global TracingProvider.")
 @Execution(ExecutionMode.SAME_THREAD)
+@Disabled("Tracing tests need to be disabled until the discrepancy with the core is resolved.")
 public class TracingIntegrationTests extends IntegrationTestBase {
     private static final byte[] CONTENTS_BYTES = "Some-contents".getBytes(StandardCharsets.UTF_8);
     private static final String PARTITION_ID = "0";
     private static final Duration DEFAULT_TIMEOUT = Duration.ofSeconds(30);
 
     private final AtomicReference<TokenCredential> cachedCredential = new AtomicReference<>();
 
-    // delemete
     private TestSpanProcessor spanProcessor;
     private EventHubProducerAsyncClient producer;
     private EventHubConsumerAsyncClient consumer;
@@ -249,11 +250,6 @@ public void sendAndReceiveParallel() throws InterruptedException {
         int messageCount = 5;
         CountDownLatch latch = new CountDownLatch(messageCount);
         spanProcessor.notifyIfCondition(latch, span -> span.getName().equals("EventHubs.consume"));
-
-        StepVerifier.create(producer.send(data, new SendOptions()))
-            .expectComplete()
-            .verify(DEFAULT_TIMEOUT);
-
         StepVerifier.create(consumer
                 .receive()
                 .take(messageCount)
@@ -273,6 +269,10 @@ public void sendAndReceiveParallel() throws InterruptedException {
             .expectComplete()
             .verify(DEFAULT_TIMEOUT);
 
+        StepVerifier.create(producer.send(data, new SendOptions()))
+            .expectComplete()
+            .verify(DEFAULT_TIMEOUT);
+
         assertTrue(latch.await(20, TimeUnit.SECONDS));
         List<ReadableSpan> spans = spanProcessor.getEndedSpans();
         List<ReadableSpan> received = findSpans(spans, "EventHubs.consume");
@@ -769,7 +769,7 @@ public void onEnd(ReadableSpan readableSpan) {
             assertEquals("Microsoft.EventHub", readableSpan.getAttribute(AttributeKey.stringKey("az.namespace")));
             assertEquals("eventhubs", readableSpan.getAttribute(AttributeKey.stringKey("messaging.system")));
             assertEquals(entityName, readableSpan.getAttribute(AttributeKey.stringKey("messaging.destination.name")));
-            assertEquals(namespace, readableSpan.getAttribute(AttributeKey.stringKey("server.address")));
+            assertEquals(namespace, readableSpan.getAttribute(AttributeKey.stringKey("net.peer.name")));
         }
 
         public void notifyIfCondition(CountDownLatch countDownLatch, Predicate<ReadableSpan> filter) {