[fix][build] Fix code style

Signed-off-by: Zixuan Liu <nodeces@gmail.com>
apache · May 13, 2024 · f89fa72 · f89fa72
1 parent 6da3c15
commit f89fa72
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 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
@@ -49,7 +49,6 @@
 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
@@ -1193,7 +1193,8 @@ private CompletableFuture<Optional<Topic>> createNonPersistentTopic(String topic
             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
@@ -322,24 +322,21 @@ CompletableFuture<MessageId> internalSendAsync(Message<?> message) {
             interceptorMessage.getProperties();
         }
 
-        int msgSize = interceptorMessage.getDataBuffer().readableBytes();
-        sendAsync(interceptorMessage, new DefaultSendMessageCallback(future, interceptorMessage, msgSize));
+        sendAsync(interceptorMessage, new DefaultSendMessageCallback(future, interceptorMessage));
         return future;
     }
 
     private class DefaultSendMessageCallback implements SendCallback {
 
         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