Fix lint

Author: Tony Cui

java-pubsub/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/OpenTelemetryPubsubTracer.java

@@ -178,8 +178,7 @@ void endPublishBatchingSpan(PubsubMessageWrapper message) {
    * Creates, starts, and returns a publish RPC span for the given message batch. Bi-directional
    * links with the publisher parent span are created for sampled messages in the batch.
    */
-  Span startPublishRpcSpan(
-      TopicName topicName, List<PubsubMessageWrapper> messages) {
+  Span startPublishRpcSpan(TopicName topicName, List<PubsubMessageWrapper> messages) {
     return startPublishRpcSpan(topicName, messages, 0);
   }
 

java-pubsub/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/Publisher.java

@@ -48,7 +48,6 @@
 import com.google.cloud.pubsub.v1.stub.PublisherStub;
 import com.google.cloud.pubsub.v1.stub.PublisherStubSettings;
 import com.google.common.base.Preconditions;
-import com.google.common.collect.ImmutableList;
 import com.google.common.collect.ImmutableMap;
 import com.google.common.collect.ImmutableSet;
 import com.google.protobuf.CodedOutputStream;
@@ -733,8 +732,7 @@ public void run() {
     ApiFuture<PublishResponse> firstAttemptFuture = publishCall(outstandingBatch);
     coordinator.addAttempt(0, firstAttemptFuture);
     long delayMs = hedgeSettings.getHedgeDelay().toMillis();
-    HedgedRequest item =
-        new HedgedRequest(coordinator, 1, clock.millisTime() + delayMs);
+    HedgedRequest item = new HedgedRequest(coordinator, 1, clock.millisTime() + delayMs);
     hedgingQueue.add(item);
     coordinator.isInQueue.set(true);
     scheduleQueueProcessing();

java-pubsub/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/OpenTelemetryTest.java

@@ -672,13 +672,11 @@ public void testHedgedPublishSpanEvents() {
     tracer.startPublisherSpan(messageWrapper);
 
     // Original Attempt 0
-    Span publishRpcSpan1 =
-        tracer.startPublishRpcSpan(FULL_TOPIC_NAME, messageWrappers, 0);
+    Span publishRpcSpan1 = tracer.startPublishRpcSpan(FULL_TOPIC_NAME, messageWrappers, 0);
     tracer.endPublishRpcSpan(publishRpcSpan1);
 
     // Hedged Attempt 1
-    Span publishRpcSpan2 =
-        tracer.startPublishRpcSpan(FULL_TOPIC_NAME, messageWrappers, 1);
+    Span publishRpcSpan2 = tracer.startPublishRpcSpan(FULL_TOPIC_NAME, messageWrappers, 1);
     tracer.endPublishRpcSpan(publishRpcSpan2);
 
     // End Publisher span

java-pubsub/google-cloud-pubsub/src/test/java/com/google/cloud/pubsub/v1/PublisherImplTest.java

@@ -1533,8 +1533,7 @@ public void testHedgingTriggeredIfSlow() throws Exception {
     List<Metadata> capturedHeaders = testPublisherServiceImpl.getCapturedHeaders();
     assertThat(capturedHeaders).hasSize(2);
     Metadata.Key<String> hedgedHeaderKey =
-        Metadata.Key.of(
-            "x-goog-pubsub-hedged-count", Metadata.ASCII_STRING_MARSHALLER);
+        Metadata.Key.of("x-goog-pubsub-hedged-count", Metadata.ASCII_STRING_MARSHALLER);
     // Original request should NOT have the header
     assertThat(capturedHeaders.get(0).get(hedgedHeaderKey)).isNull();
     // First hedged request should have value "1"
@@ -1577,8 +1576,7 @@ public void testMultipleHedging() throws Exception {
     List<Metadata> capturedHeaders = testPublisherServiceImpl.getCapturedHeaders();
     assertThat(capturedHeaders).hasSize(3);
     Metadata.Key<String> hedgedHeaderKey =
-        Metadata.Key.of(
-            "x-goog-pubsub-hedged-count", Metadata.ASCII_STRING_MARSHALLER);
+        Metadata.Key.of("x-goog-pubsub-hedged-count", Metadata.ASCII_STRING_MARSHALLER);
     assertThat(capturedHeaders.get(0).get(hedgedHeaderKey)).isNull();
     assertThat(capturedHeaders.get(1).get(hedgedHeaderKey)).isEqualTo("1");
     assertThat(capturedHeaders.get(2).get(hedgedHeaderKey)).isEqualTo("2");