Convert rocketmq unit test from groovy to java (#10520)

Author: steverao

instrumentation/rocketmq/rocketmq-client/rocketmq-client-4.8/javaagent/src/test/groovy/io/opentelemetry/instrumentation/rocketmqclient/v4_8/RocketMqClientTest.groovy

@@ -0,0 +1,29 @@
+/*
+ * Copyright The OpenTelemetry Authors
+ * SPDX-License-Identifier: Apache-2.0
+ */
+
+package io.opentelemetry.instrumentation.rocketmqclient.v4_8;
+
+import io.opentelemetry.instrumentation.testing.junit.AgentInstrumentationExtension;
+import io.opentelemetry.instrumentation.testing.junit.InstrumentationExtension;
+import org.apache.rocketmq.client.consumer.DefaultMQPushConsumer;
+import org.apache.rocketmq.client.producer.DefaultMQProducer;
+import org.junit.jupiter.api.extension.RegisterExtension;
+
+class RocketMqClientTest extends AbstractRocketMqClientTest {
+
+  @RegisterExtension
+  private static final InstrumentationExtension testing = AgentInstrumentationExtension.create();
+
+  @Override
+  InstrumentationExtension testing() {
+    return testing;
+  }
+
+  @Override
+  void configureMqProducer(DefaultMQProducer producer) {}
+
+  @Override
+  void configureMqPushConsumer(DefaultMQPushConsumer consumer) {}
+}

instrumentation/rocketmq/rocketmq-client/rocketmq-client-4.8/javaagent/src/test/java/io/opentelemetry/instrumentation/rocketmqclient/v4_8/RocketMqClientTest.java

@@ -0,0 +1,53 @@
+/*
+ * Copyright The OpenTelemetry Authors
+ * SPDX-License-Identifier: Apache-2.0
+ */
+
+package io.opentelemetry.instrumentation.rocketmqclient.v4_8;
+
+import static java.util.Collections.singletonList;
+
+import io.opentelemetry.instrumentation.testing.junit.InstrumentationExtension;
+import io.opentelemetry.instrumentation.testing.junit.LibraryInstrumentationExtension;
+import org.apache.rocketmq.client.consumer.DefaultMQPushConsumer;
+import org.apache.rocketmq.client.producer.DefaultMQProducer;
+import org.junit.jupiter.api.extension.RegisterExtension;
+
+class RocketMqClientTest extends AbstractRocketMqClientTest {
+
+  @RegisterExtension
+  private static final InstrumentationExtension testing = LibraryInstrumentationExtension.create();
+
+  @Override
+  InstrumentationExtension testing() {
+    return testing;
+  }
+
+  @Override
+  @SuppressWarnings("deprecation")
+  // testing instrumentation of deprecated class
+  void configureMqProducer(DefaultMQProducer producer) {
+    producer
+        .getDefaultMQProducerImpl()
+        .registerSendMessageHook(
+            RocketMqTelemetry.builder(testing.getOpenTelemetry())
+                .setCapturedHeaders(singletonList("test-message-header"))
+                .setCaptureExperimentalSpanAttributes(true)
+                .build()
+                .newTracingSendMessageHook());
+  }
+
+  @Override
+  @SuppressWarnings("deprecation")
+  // testing instrumentation of deprecated class
+  void configureMqPushConsumer(DefaultMQPushConsumer consumer) {
+    consumer
+        .getDefaultMQPushConsumerImpl()
+        .registerConsumeMessageHook(
+            RocketMqTelemetry.builder(testing.getOpenTelemetry())
+                .setCapturedHeaders(singletonList("test-message-header"))
+                .setCaptureExperimentalSpanAttributes(true)
+                .build()
+                .newTracingConsumeMessageHook());
+  }
+}