This is an automated email from the ASF dual-hosted git repository.
aaronai pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-clients.git
The following commit(s) were added to refs/heads/master by this push:
new 76466e4 Add more comments for ProducerImpl#send0 (#259)
76466e4 is described below
commit 76466e4e5177ed5fc2175ab4939c1b90d8a73126
Author: Aaron Ai <[email protected]>
AuthorDate: Mon Oct 17 13:26:36 2022 +0800
Add more comments for ProducerImpl#send0 (#259)
---
.../org/apache/rocketmq/client/java/impl/producer/ProducerImpl.java | 3 +++
1 file changed, 3 insertions(+)
diff --git
a/java/client/src/main/java/org/apache/rocketmq/client/java/impl/producer/ProducerImpl.java
b/java/client/src/main/java/org/apache/rocketmq/client/java/impl/producer/ProducerImpl.java
index 40a0e13..307af8a 100644
---
a/java/client/src/main/java/org/apache/rocketmq/client/java/impl/producer/ProducerImpl.java
+++
b/java/client/src/main/java/org/apache/rocketmq/client/java/impl/producer/ProducerImpl.java
@@ -428,6 +428,9 @@ class ProducerImpl extends ClientImpl implements Producer {
MoreExecutors.directExecutor());
}
+ /**
+ * Warning: please DO NOT modify the signature of this method, it is used
by OpenTelemetry instrumentation.
+ */
private void send0(SettableFuture<List<SendReceiptImpl>> future0, String
topic, MessageType messageType,
final List<MessageQueueImpl> candidates, final
List<PublishingMessageImpl> messages, final int attempt) {
// Calculate the current message queue.