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