[fix] change checkstyle.xml

Author: StevenLuMT

pulsar-admin-mcp-contrib/src/test/java/org/apache/pulsar/admin/mcp/transport/TransportManagerTest.java

@@ -20,6 +20,7 @@
 import static org.mockito.Mockito.verify;
 import static org.mockito.Mockito.verifyNoMoreInteractions;
 import static org.mockito.Mockito.when;
+
 import org.apache.pulsar.admin.mcp.config.PulsarMCPCliOptions;
 import org.testng.annotations.BeforeMethod;
 import org.testng.annotations.Test;

pulsar-rpc-contrib/src/main/java/org/apache/pulsar/rpc/contrib/client/PulsarRpcClientImpl.java

@@ -15,6 +15,7 @@
 
 import static lombok.AccessLevel.PACKAGE;
 import static org.apache.pulsar.rpc.contrib.common.Constants.REQUEST_DELIVER_AT_TIME;
+
 import java.io.IOException;
 import java.time.Duration;
 import java.util.Map;

pulsar-rpc-contrib/src/main/java/org/apache/pulsar/rpc/contrib/client/ReplyListener.java

@@ -16,6 +16,7 @@
 import static org.apache.pulsar.rpc.contrib.common.Constants.ERROR_MESSAGE;
 import static org.apache.pulsar.rpc.contrib.common.Constants.REQUEST_DELIVER_AT_TIME;
 import static org.apache.pulsar.rpc.contrib.common.Constants.SERVER_SUB;
+
 import java.util.concurrent.CompletableFuture;
 import java.util.concurrent.ConcurrentHashMap;
 import lombok.AccessLevel;

pulsar-rpc-contrib/src/main/java/org/apache/pulsar/rpc/contrib/client/RequestSender.java

@@ -15,6 +15,7 @@
 
 import static org.apache.pulsar.rpc.contrib.common.Constants.REPLY_TOPIC;
 import static org.apache.pulsar.rpc.contrib.common.Constants.REQUEST_TIMEOUT_MILLIS;
+
 import java.util.concurrent.CompletableFuture;
 import lombok.AccessLevel;
 import lombok.RequiredArgsConstructor;

pulsar-rpc-contrib/src/main/java/org/apache/pulsar/rpc/contrib/common/MessageDispatcherFactory.java

@@ -14,6 +14,7 @@
 package org.apache.pulsar.rpc.contrib.common;
 
 import static java.util.concurrent.TimeUnit.MILLISECONDS;
+
 import java.io.IOException;
 import java.time.Duration;
 import java.util.Map;

pulsar-rpc-contrib/src/main/java/org/apache/pulsar/rpc/contrib/server/PulsarRpcServerImpl.java

@@ -14,6 +14,7 @@
 package org.apache.pulsar.rpc.contrib.server;
 
 import static lombok.AccessLevel.PACKAGE;
+
 import java.io.IOException;
 import java.util.concurrent.CompletableFuture;
 import java.util.function.BiConsumer;

pulsar-rpc-contrib/src/main/java/org/apache/pulsar/rpc/contrib/server/ReplySender.java

@@ -16,6 +16,7 @@
 import static org.apache.pulsar.rpc.contrib.common.Constants.ERROR_MESSAGE;
 import static org.apache.pulsar.rpc.contrib.common.Constants.REQUEST_DELIVER_AT_TIME;
 import static org.apache.pulsar.rpc.contrib.common.Constants.SERVER_SUB;
+
 import java.util.function.BiConsumer;
 import lombok.AccessLevel;
 import lombok.RequiredArgsConstructor;

pulsar-rpc-contrib/src/main/java/org/apache/pulsar/rpc/contrib/server/RequestListener.java

@@ -16,6 +16,7 @@
 import static org.apache.pulsar.rpc.contrib.common.Constants.REPLY_TOPIC;
 import static org.apache.pulsar.rpc.contrib.common.Constants.REQUEST_DELIVER_AT_TIME;
 import static org.apache.pulsar.rpc.contrib.common.Constants.REQUEST_TIMEOUT_MILLIS;
+
 import java.util.concurrent.CompletableFuture;
 import java.util.concurrent.ExecutionException;
 import java.util.concurrent.TimeUnit;

pulsar-rpc-contrib/src/test/java/org/apache/pulsar/rpc/contrib/base/PulsarRpcBase.java

@@ -14,6 +14,7 @@
 package org.apache.pulsar.rpc.contrib.base;
 
 import static java.util.UUID.randomUUID;
+
 import java.time.Duration;
 import java.util.function.Supplier;
 import java.util.regex.Pattern;

pulsar-transaction-contrib/src/test/java/org/apache/pulsar/txn/TransactionImplTest.java

@@ -22,6 +22,7 @@
 import static org.mockito.Mockito.when;
 import static org.testng.Assert.assertEquals;
 import static org.testng.Assert.assertTrue;
+
 import java.util.ArrayList;
 import java.util.List;
 import java.util.concurrent.CompletableFuture;
@@ -87,7 +88,8 @@ public void testAckAllReceivedMsgsAsync() throws ExecutionException, Interrupted
     CompletableFuture<Void> future = transactionImpl.ackAllReceivedMsgsAsync();
     future.get();
 
-    // Verify each consumer called the correct acknowledgeAsync method with the correct message IDs
+    // Verify each consumer called the correct acknowledgeAsync method with the correct message
+    // IDs
     for (int i = 0; i < mockConsumers.size(); i++) {
       Consumer<?> consumer = mockConsumers.get(i);
       MessageId messageId = messageIds.get(i);
@@ -109,7 +111,8 @@ public void testAckAllReceivedMsgs() throws ExecutionException, InterruptedExcep
     // Call the ackAllReceivedMsgs method
     transactionImpl.ackAllReceivedMsgs(consumer);
 
-    // Verify the consumer called the correct acknowledgeAsync method with the correct message IDs
+    // Verify the consumer called the correct acknowledgeAsync method with the correct message
+    // IDs
     verify(consumer).acknowledgeAsync(eq(List.of(messageId)), eq(mockTransaction));
     // Verify the message Ids were removed from the transaction context after acked.
     assertEquals(transactionImpl.getReceivedMessages().size(), 0);
@@ -133,7 +136,8 @@ public void testAckAllReceivedMsgsAll() throws ExecutionException, InterruptedEx
     // Call the ackAllReceivedMsgs method
     transactionImpl.ackAllReceivedMsgs();
 
-    // Verify each consumer called the correct acknowledgeAsync method with the correct message IDs
+    // Verify each consumer called the correct acknowledgeAsync method with the correct message
+    // IDs
     for (int i = 0; i < mockConsumers.size(); i++) {
       Consumer<?> consumer = mockConsumers.get(i);
       MessageId messageId = messageIds.get(i);
@@ -160,7 +164,8 @@ public void testAckAllReceivedMsgsAsyncAll() throws ExecutionException, Interrup
     CompletableFuture<Void> future = transactionImpl.ackAllReceivedMsgsAsync();
     future.get();
 
-    // Verify each consumer called the correct acknowledgeAsync method with the correct message IDs
+    // Verify each consumer called the correct acknowledgeAsync method with the correct message
+    // IDs
     for (int i = 0; i < mockConsumers.size(); i++) {
       Consumer<?> consumer = mockConsumers.get(i);
       MessageId messageId = messageIds.get(i);