(pulsar) branch branch-2.10 updated: [fix][build] Fix code style

[zixuan]

This is an automated email from the ASF dual-hosted git repository.

zixuan pushed a commit to branch branch-2.10
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/branch-2.10 by this push:
     new f89fa720a78 [fix][build] Fix code style
f89fa720a78 is described below

commit f89fa720a782c8071cce6fc02fdacb0d47e758db
Author: Zixuan Liu <node...@gmail.com>
AuthorDate: Mon May 13 16:58:53 2024 +0800

    [fix][build] Fix code style
    
    Signed-off-by: Zixuan Liu <node...@gmail.com>
---
 .../main/java/org/apache/pulsar/broker/admin/impl/BrokersBase.java | 1 -
 .../main/java/org/apache/pulsar/broker/service/BrokerService.java  | 3 ++-
 .../src/main/java/org/apache/pulsar/client/impl/ProducerImpl.java  | 7 ++-----
 3 files changed, 4 insertions(+), 7 deletions(-)

diff --git 
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/BrokersBase.java
 
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/BrokersBase.java
index 57fdf6f2849..c040d2c268c 100644
--- 
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/BrokersBase.java
+++ 
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/BrokersBase.java
@@ -49,7 +49,6 @@ import org.apache.pulsar.broker.ServiceConfiguration;
 import org.apache.pulsar.broker.admin.AdminResource;
 import org.apache.pulsar.broker.loadbalance.LeaderBroker;
 import org.apache.pulsar.broker.namespace.NamespaceService;
-import org.apache.pulsar.broker.service.BrokerService;
 import org.apache.pulsar.broker.service.Subscription;
 import org.apache.pulsar.broker.service.Topic;
 import org.apache.pulsar.broker.web.RestException;
diff --git 
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BrokerService.java
 
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BrokerService.java
index f6103dbae76..11840f3c89a 100644
--- 
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BrokerService.java
+++ 
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/BrokerService.java
@@ -1193,7 +1193,8 @@ public class BrokerService implements Closeable {
             if (log.isDebugEnabled()) {
                 log.debug("Broker is unable to load non-persistent topic {}", 
topic);
             }
-            topicFuture.completeExceptionally(new NotAllowedException("Broker 
is not unable to load non-persistent topic"));
+            topicFuture.completeExceptionally(
+                    new NotAllowedException("Broker is not unable to load 
non-persistent topic"));
             return topicFuture;
         }
         final long topicCreateTimeMs = 
TimeUnit.NANOSECONDS.toMillis(System.nanoTime());
diff --git 
a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ProducerImpl.java 
b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ProducerImpl.java
index b1afe95465d..cb6164b9888 100644
--- 
a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ProducerImpl.java
+++ 
b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ProducerImpl.java
@@ -322,8 +322,7 @@ public class ProducerImpl<T> extends ProducerBase<T> 
implements TimerTask, Conne
             interceptorMessage.getProperties();
         }
 
-        int msgSize = interceptorMessage.getDataBuffer().readableBytes();
-        sendAsync(interceptorMessage, new DefaultSendMessageCallback(future, 
interceptorMessage, msgSize));
+        sendAsync(interceptorMessage, new DefaultSendMessageCallback(future, 
interceptorMessage));
         return future;
     }
 
@@ -331,15 +330,13 @@ public class ProducerImpl<T> extends ProducerBase<T> 
implements TimerTask, Conne
 
         CompletableFuture<MessageId> sendFuture;
         MessageImpl<?> currentMsg;
-        int msgSize;
         long createdAt = System.nanoTime();
         SendCallback nextCallback = null;
         MessageImpl<?> nextMsg = null;
 
-        DefaultSendMessageCallback(CompletableFuture<MessageId> sendFuture, 
MessageImpl<?> currentMsg, int msgSize) {
+        DefaultSendMessageCallback(CompletableFuture<MessageId> sendFuture, 
MessageImpl<?> currentMsg) {
             this.sendFuture = sendFuture;
             this.currentMsg = currentMsg;
-            this.msgSize = msgSize;
         }
 
         @Override