feat: Make OTel classes/methods package-private and remove non-generi…

…c PubsubTracer interface
googleapis · Sep 25, 2024 · fe4753f · fe4753f
1 parent 79dd118
commit fe4753f
Show file tree

Hide file tree

Showing 10 changed files with 192 additions and 326 deletions.
diff --git a/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/BasePubsubTracer.java b/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/BasePubsubTracer.java
diff --git a/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/MessageDispatcher.java b/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/MessageDispatcher.java
@@ -106,7 +106,7 @@ class MessageDispatcher {
 
   private final String subscriptionName;
   private final boolean enableOpenTelemetryTracing;
-  private PubsubTracer tracer = new BasePubsubTracer();
+  private OpenTelemetryPubsubTracer tracer = new OpenTelemetryPubsubTracer(null, false);
 
   /** Internal representation of a reply to a Pubsub message, to be sent back to the service. */
   public enum AckReply {
@@ -688,7 +688,7 @@ public static final class Builder {
 
     private String subscriptionName;
     private boolean enableOpenTelemetryTracing;
-    private PubsubTracer tracer;
+    private OpenTelemetryPubsubTracer tracer;
 
     protected Builder(MessageReceiver receiver) {
       this.receiver = receiver;
@@ -770,7 +770,7 @@ public Builder setEnableOpenTelemetryTracing(boolean enableOpenTelemetryTracing)
       return this;
     }
 
-    public Builder setTracer(PubsubTracer tracer) {
+    public Builder setTracer(OpenTelemetryPubsubTracer tracer) {
       this.tracer = tracer;
       return this;
     }