Update TracingDecoratorTest.java

remove automatically added io.quarkiverse.kafkastreamsprocessor.impl.decorator.processor.TracingDecoratorTest prefix to used classes

Author: libourel06

impl/src/test/java/io/quarkiverse/kafkastreamsprocessor/impl/decorator/processor/TracingDecoratorTest.java

@@ -101,7 +101,7 @@
 public class TracingDecoratorTest {
     // header value format here: https://www.w3.org/TR/trace-context/#traceparent-header
     private static final String TRACE_PARENT = w3cHeader("1", "9");
-    private static final String PROCESSOR_NAME = io.quarkiverse.kafkastreamsprocessor.impl.decorator.processor.TracingDecoratorTest.MockType.class.getName();
+    private static final String PROCESSOR_NAME = MockType.class.getName();
     private static final Formatter LOG_FORMATTER = new PatternFormatter("%p %s %e");
     private static final InMemoryLogHandler inMemoryLogHandler = new InMemoryLogHandler(record -> true);
     private static final java.util.logging.Logger rootLogger = LogManager.getLogManager().getLogger("io.quarkiverse");
@@ -115,7 +115,7 @@ public class TracingDecoratorTest {
     JsonFormat.Printer jsonPrinter;
 
     @Spy
-    io.quarkiverse.kafkastreamsprocessor.impl.decorator.processor.TracingDecoratorTest.ReadMDCProcessor kafkaProcessor;
+    ReadMDCProcessor kafkaProcessor;
 
     @Mock
     InternalProcessorContext<String, Ping> processorContext;
@@ -134,7 +134,7 @@ public void setUp() {
         inMemoryLogHandler.getRecords().clear();
         rootLogger.addHandler(inMemoryLogHandler);
         rootLogger.setLevel(Level.DEBUG);
-        when(topologyConfiguration.getProcessorPayloadType()).thenReturn((Class) io.quarkiverse.kafkastreamsprocessor.impl.decorator.processor.TracingDecoratorTest.MockType.class);
+        when(topologyConfiguration.getProcessorPayloadType()).thenReturn((Class) MockType.class);
         decorator = new TracingDecorator(otel.getOpenTelemetry(), kafkaTextMapGetter,
             kafkaTextMapSetter, tracer, topologyConfiguration.getProcessorPayloadType().getName(),
             jsonPrinter);
@@ -206,7 +206,7 @@ public void shouldCleanMDCAndScopeInCaseOfException() {
             decorator = new TracingDecorator(otel.getOpenTelemetry(), kafkaTextMapGetter,
                 kafkaTextMapSetter,
                 tracer, topologyConfiguration.getProcessorPayloadType().getName(), jsonPrinter);
-            decorator.setDelegate(new io.quarkiverse.kafkastreamsprocessor.impl.decorator.processor.TracingDecoratorTest.ThrowExceptionProcessor());
+            decorator.setDelegate(new ThrowExceptionProcessor());
             decorator.init(processorContext);
 
             assertDoesNotThrow(() -> decorator.process(record));
@@ -329,7 +329,7 @@ void shouldPropagateOpentelemetryW3CBaggage() {
         Record<String, Ping> record = new Record<>(null, Ping.newBuilder().setMessage("blabla").build(), 0L, headers);
         decorator = new TracingDecorator(otel.getOpenTelemetry(), kafkaTextMapGetter, kafkaTextMapSetter,
             tracer, topologyConfiguration.getProcessorPayloadType().getName(), jsonPrinter);
-        decorator.setDelegate(new io.quarkiverse.kafkastreamsprocessor.impl.decorator.processor.TracingDecoratorTest.LogOpentelemetryBaggageProcessor());
+        decorator.setDelegate(new LogOpentelemetryBaggageProcessor());
         decorator.init(processorContext);
 
         decorator.process(record);