feat: Lint fixes for Pub/Sub

googleapis · Sep 25, 2024 · a08d169 · a08d169
1 parent fe4753f
commit a08d169
Show file tree

Hide file tree

Showing 3 changed files with 9 additions and 11 deletions.
diff --git a/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/OpenTelemetryPubsubTracer.java b/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/OpenTelemetryPubsubTracer.java
@@ -229,8 +229,7 @@ void setPublishRpcSpanException(Span publishRpcSpan, Throwable t) {
     }
   }
 
-  void startSubscriberSpan(
-      PubsubMessageWrapper message, boolean exactlyOnceDeliveryEnabled) {
+  void startSubscriberSpan(PubsubMessageWrapper message, boolean exactlyOnceDeliveryEnabled) {
     if (!enabled) {
       return;
     }
@@ -275,8 +274,7 @@ void setSubscriberSpanExpirationResult(PubsubMessageWrapper message) {
     message.setSubscriberSpanExpirationResult();
   }
 
-  void setSubscriberSpanException(
-      PubsubMessageWrapper message, Throwable t, String exception) {
+  void setSubscriberSpanException(PubsubMessageWrapper message, Throwable t, String exception) {
     if (!enabled) {
       return;
     }
@@ -302,8 +300,7 @@ void endSubscribeConcurrencyControlSpan(PubsubMessageWrapper message) {
     message.endSubscribeConcurrencyControlSpan();
   }
 
-  void setSubscribeConcurrencyControlSpanException(
-      PubsubMessageWrapper message, Throwable t) {
+  void setSubscribeConcurrencyControlSpanException(PubsubMessageWrapper message, Throwable t) {
     if (!enabled) {
       return;
     }
@@ -434,8 +431,7 @@ void endSubscribeRpcSpan(Span rpcSpan) {
    * Sets an error status and records an exception when an exception is thrown when handling a
    * subscribe-side RPC.
    */
-  void setSubscribeRpcSpanException(
-      Span rpcSpan, boolean isModack, int ackDeadline, Throwable t) {
+  void setSubscribeRpcSpanException(Span rpcSpan, boolean isModack, int ackDeadline, Throwable t) {
     if (!enabled) {
       return;
     }

diff --git a/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/Publisher.java b/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/Publisher.java
@@ -166,7 +166,8 @@ private Publisher(Builder builder) throws IOException {
     if (this.openTelemetry != null && this.enableOpenTelemetryTracing) {
       Tracer openTelemetryTracer = builder.openTelemetry.getTracer(OPEN_TELEMETRY_TRACER_NAME);
       if (openTelemetryTracer != null) {
-        this.tracer = new OpenTelemetryPubsubTracer(openTelemetryTracer, this.enableOpenTelemetryTracing);
+        this.tracer =
+            new OpenTelemetryPubsubTracer(openTelemetryTracer, this.enableOpenTelemetryTracing);
       }
     }
 

diff --git a/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/Subscriber.java b/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/Subscriber.java
@@ -151,7 +151,7 @@ public class Subscriber extends AbstractApiService implements SubscriberInterfac
 
   private final boolean enableOpenTelemetryTracing;
   private final OpenTelemetry openTelemetry;
-  private OpenTelemetryPubsubTracer tracer = new OpenTelemetryPubsubTracer(null,  false);
+  private OpenTelemetryPubsubTracer tracer = new OpenTelemetryPubsubTracer(null, false);
 
   private Subscriber(Builder builder) {
     receiver = builder.receiver;
@@ -212,7 +212,8 @@ private Subscriber(Builder builder) {
     if (this.openTelemetry != null && this.enableOpenTelemetryTracing) {
       Tracer openTelemetryTracer = builder.openTelemetry.getTracer(OPEN_TELEMETRY_TRACER_NAME);
       if (openTelemetryTracer != null) {
-        this.tracer = new OpenTelemetryPubsubTracer(openTelemetryTracer, this.enableOpenTelemetryTracing);
+        this.tracer =
+            new OpenTelemetryPubsubTracer(openTelemetryTracer, this.enableOpenTelemetryTracing);
       }
     }