fix build

open-telemetry · Oct 10, 2021 · fdd7984 · fdd7984
1 parent 910bc78
commit fdd7984
Show file tree

Hide file tree

Showing 3 changed files with 12 additions and 12 deletions.
diff --git a/...est/groovy/io/opentelemetry/instrumentation/lettuce/v5_1/LettuceReactiveClientTest.groovy b/...est/groovy/io/opentelemetry/instrumentation/lettuce/v5_1/LettuceReactiveClientTest.groovy
@@ -7,13 +7,13 @@ package io.opentelemetry.instrumentation.lettuce.v5_1
 
 import io.lettuce.core.RedisClient
 import io.lettuce.core.resource.ClientResources
-import io.opentelemetry.instrumentation.reactor.ContextPropagationReactorOperator
+import io.opentelemetry.instrumentation.reactor.ContextPropagationOperator
 import io.opentelemetry.instrumentation.test.LibraryTestTrait
 import spock.lang.Shared
 
 class LettuceReactiveClientTest extends AbstractLettuceReactiveClientTest implements LibraryTestTrait {
   @Shared
-  ContextPropagationReactorOperator tracingOperator = ContextPropagationReactorOperator.create()
+  ContextPropagationOperator ContextPropagationOperator = ContextPropagationReactorOperator.create()
 
   @Override
   RedisClient createClient(String uri) {
@@ -25,10 +25,10 @@ class LettuceReactiveClientTest extends AbstractLettuceReactiveClientTest implem
   }
 
   def setupSpec() {
-    tracingOperator.registerOnEachOperator()
+    ContextPropagationOperator.registerOnEachOperator()
   }
 
   def cleanupSpec() {
-    tracingOperator.resetOnEachOperator()
+    ContextPropagationOperator.resetOnEachOperator()
   }
 }
diff --git a/...1/library/src/test/groovy/io/opentelemetry/instrumentation/reactor/ReactorCoreTest.groovy b/...1/library/src/test/groovy/io/opentelemetry/instrumentation/reactor/ReactorCoreTest.groovy
@@ -17,14 +17,14 @@ import spock.lang.Shared
 
 class ReactorCoreTest extends AbstractReactorCoreTest implements LibraryTestTrait {
   @Shared
-  ContextPropagationOperator tracingOperator = ContextPropagationOperator.create()
+  ContextPropagationOperator ContextPropagationOperator = ContextPropagationOperator.create()
 
   def setupSpec() {
-    tracingOperator.registerOnEachOperator()
+    ContextPropagationOperator.registerOnEachOperator()
   }
 
   def cleanupSpec() {
-    tracingOperator.resetOnEachOperator()
+    ContextPropagationOperator.resetOnEachOperator()
   }
 
   def "Current in non-blocking publisher assembly"() {
@@ -125,7 +125,7 @@ class ReactorCoreTest extends AbstractReactorCoreTest implements LibraryTestTrai
 
   def "No tracing before registration"() {
     when:
-    tracingOperator.resetOnEachOperator()
+    ContextPropagationOperator.resetOnEachOperator()
 
     def result1 = Mono.fromCallable({ ->
       assert !Span.current().getSpanContext().isValid() : "current span is not set"
@@ -141,7 +141,7 @@ class ReactorCoreTest extends AbstractReactorCoreTest implements LibraryTestTrai
             assert !Span.current().getSpanContext().isValid() : "current span is not set"
           })}).block()
 
-    tracingOperator.registerOnEachOperator()
+    ContextPropagationOperator.registerOnEachOperator()
     def result2 = Mono.fromCallable({ ->
       assert Span.current().getSpanContext().isValid() : "current span is set"
       return 2

diff --git a/.../library/src/test/groovy/io/opentelemetry/instrumentation/reactor/SubscriptionTest.groovy b/.../library/src/test/groovy/io/opentelemetry/instrumentation/reactor/SubscriptionTest.groovy
@@ -10,13 +10,13 @@ import spock.lang.Shared
 
 class SubscriptionTest extends AbstractSubscriptionTest implements LibraryTestTrait {
   @Shared
-  ContextPropagationOperator tracingOperator = ContextPropagationOperator.create()
+  ContextPropagationOperator ContextPropagationOperator = ContextPropagationOperator.create()
 
   def setupSpec() {
-    tracingOperator.registerOnEachOperator()
+    ContextPropagationOperator.registerOnEachOperator()
   }
 
   def cleanupSpec() {
-    tracingOperator.resetOnEachOperator()
+    ContextPropagationOperator.resetOnEachOperator()
   }
 }