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

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


The following commit(s) were added to refs/heads/branch-3.2 by this push:
     new be9b97d1ccc Remove unused fields `msgSize`
be9b97d1ccc is described below

commit be9b97d1ccc1ee2485ad8579aa81a94542cc5b1f
Author: coderzc <[email protected]>
AuthorDate: Fri Apr 12 15:35:56 2024 +0800

    Remove unused fields `msgSize`
---
 .../src/main/java/org/apache/pulsar/client/impl/ProducerImpl.java       | 2 --
 1 file changed, 2 deletions(-)

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 04dfb01eeaa..1d1df7942ab 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
@@ -347,7 +347,6 @@ 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;
@@ -355,7 +354,6 @@ public class ProducerImpl<T> extends ProducerBase<T> 
implements TimerTask, Conne
         DefaultSendMessageCallback(CompletableFuture<MessageId> sendFuture, 
MessageImpl<?> currentMsg, int msgSize) {
             this.sendFuture = sendFuture;
             this.currentMsg = currentMsg;
-            this.msgSize = msgSize;
         }
 
         @Override

Reply via email to