Update

Author: CodePrometheus

instrumentation/spring/spring-pulsar-1.2/javaagent/build.gradle.kts

@@ -7,6 +7,7 @@ muzzle {
     group.set("org.springframework.pulsar")
     module.set("spring-pulsar")
     versions.set("[1.2.0,)")
+    assertInverse.set(true)
   }
 }
 
@@ -15,7 +16,6 @@ dependencies {
   implementation(project(":instrumentation:pulsar:pulsar-2.8:javaagent"))
 
   testInstrumentation(project(":instrumentation:pulsar:pulsar-2.8:javaagent"))
-
   testImplementation(project(":instrumentation:spring:spring-pulsar-1.2:testing"))
 
   testLibrary("org.springframework.pulsar:spring-pulsar:1.2.0")

instrumentation/spring/spring-pulsar-1.2/javaagent/src/main/java/io/opentelemetry/javaagent/instrumentation/spring/pulsar/v1_2/SpringPulsarSingletons.java

@@ -18,7 +18,6 @@
 import org.apache.pulsar.client.api.Message;
 
 public final class SpringPulsarSingletons {
-  private static final String INSTRUMENTATION_NAME = "io.opentelemetry.spring-pulsar-1.2";
   private static final Instrumenter<Message<?>, Void> INSTRUMENTER;
 
   static {
@@ -31,7 +30,7 @@ public final class SpringPulsarSingletons {
     InstrumenterBuilder<Message<?>, Void> builder =
         Instrumenter.<Message<?>, Void>builder(
                 openTelemetry,
-                INSTRUMENTATION_NAME,
+                "io.opentelemetry.spring-pulsar-1.2",
                 MessagingSpanNameExtractor.create(getter, operation))
             .addAttributesExtractor(
                 MessagingAttributesExtractor.builder(getter, operation)

instrumentation/spring/spring-pulsar-1.2/javaagent/src/test/java/io/opentelemetry/javaagent/instrumentation/spring/pulsar/v1_2/SpringPulsarTest.java

@@ -10,7 +10,7 @@
 import static io.opentelemetry.api.trace.SpanKind.PRODUCER;
 import static io.opentelemetry.instrumentation.testing.util.TelemetryDataUtil.orderByRootSpanKind;
 
-import io.opentelemetry.instrumentation.spring.pulsar.v1_0.AbstractSpringPulsarTest;
+import io.opentelemetry.instrumentation.spring.pulsar.v1_2.AbstractSpringPulsarTest;
 import io.opentelemetry.sdk.trace.data.LinkData;
 import io.opentelemetry.sdk.trace.data.SpanData;
 import java.util.concurrent.atomic.AtomicReference;

instrumentation/spring/spring-pulsar-1.2/javaagent/src/testReceiveSpansDisabled/java/io/opentelemetry/javaagent/instrumentation/spring/pulsar/v1_2/SpringPulsarSuppressReceiveSpansTest.java

@@ -8,7 +8,7 @@
 import static io.opentelemetry.api.trace.SpanKind.CONSUMER;
 import static io.opentelemetry.api.trace.SpanKind.PRODUCER;
 
-import io.opentelemetry.instrumentation.spring.pulsar.v1_0.AbstractSpringPulsarTest;
+import io.opentelemetry.instrumentation.spring.pulsar.v1_2.AbstractSpringPulsarTest;
 
 class SpringPulsarSuppressReceiveSpansTest extends AbstractSpringPulsarTest {
 

instrumentation/spring/spring-pulsar-1.2/testing/src/main/java/io/opentelemetry/instrumentation/spring/pulsar/v1_0/AbstractSpringPulsarTest.java renamed to instrumentation/spring/spring-pulsar-1.2/testing/src/main/java/io/opentelemetry/instrumentation/spring/pulsar/v1_2/AbstractSpringPulsarTest.java

@@ -3,7 +3,7 @@
  * SPDX-License-Identifier: Apache-2.0
  */
 
-package io.opentelemetry.instrumentation.spring.pulsar.v1_0;
+package io.opentelemetry.instrumentation.spring.pulsar.v1_2;
 
 import static io.opentelemetry.sdk.testing.assertj.OpenTelemetryAssertions.equalTo;
 import static io.opentelemetry.sdk.testing.assertj.OpenTelemetryAssertions.satisfies;
@@ -15,14 +15,14 @@
 import static io.opentelemetry.semconv.incubating.MessagingIncubatingAttributes.MESSAGING_MESSAGE_ID;
 import static io.opentelemetry.semconv.incubating.MessagingIncubatingAttributes.MESSAGING_OPERATION;
 import static io.opentelemetry.semconv.incubating.MessagingIncubatingAttributes.MESSAGING_SYSTEM;
+import static java.util.Arrays.asList;
 
 import io.opentelemetry.api.common.AttributeKey;
 import io.opentelemetry.instrumentation.testing.GlobalTraceUtil;
 import io.opentelemetry.instrumentation.testing.junit.AgentInstrumentationExtension;
 import io.opentelemetry.instrumentation.testing.junit.InstrumentationExtension;
 import io.opentelemetry.sdk.testing.assertj.AttributeAssertion;
 import java.time.Duration;
-import java.util.Arrays;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
@@ -113,7 +113,7 @@ static void teardown() {
       AttributeKey.stringKey("messaging.pulsar.message.type");
 
   protected List<AttributeAssertion> publishAttributes() {
-    return Arrays.asList(
+    return asList(
         equalTo(MESSAGING_SYSTEM, "pulsar"),
         equalTo(MESSAGING_OPERATION, "publish"),
         equalTo(MESSAGING_DESTINATION_NAME, OTEL_TOPIC),
@@ -125,7 +125,7 @@ protected List<AttributeAssertion> publishAttributes() {
   }
 
   protected List<AttributeAssertion> processAttributes() {
-    return Arrays.asList(
+    return asList(
         equalTo(MESSAGING_SYSTEM, "pulsar"),
         equalTo(MESSAGING_OPERATION, "process"),
         satisfies(MESSAGING_MESSAGE_BODY_SIZE, AbstractLongAssert::isNotNegative),
@@ -134,7 +134,7 @@ protected List<AttributeAssertion> processAttributes() {
   }
 
   protected List<AttributeAssertion> receiveAttributes() {
-    return Arrays.asList(
+    return asList(
         equalTo(MESSAGING_SYSTEM, "pulsar"),
         equalTo(MESSAGING_OPERATION, "receive"),
         equalTo(MESSAGING_DESTINATION_NAME, OTEL_TOPIC),