You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by vo...@apache.org on 2021/11/29 07:27:58 UTC
[rocketmq-client-go] branch master updated: Remove useless comments
This is an automated email from the ASF dual-hosted git repository.
vongosling pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-client-go.git
The following commit(s) were added to refs/heads/master by this push:
new 44d8076 Remove useless comments
44d8076 is described below
commit 44d807633e8c321089c8edc00504ec4697d2c325
Author: vongosling <vo...@apache.org>
AuthorDate: Mon Nov 29 15:27:45 2021 +0800
Remove useless comments
---
producer/producer.go | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/producer/producer.go b/producer/producer.go
index 06ea739..2ab2445 100644
--- a/producer/producer.go
+++ b/producer/producer.go
@@ -550,7 +550,7 @@ func (tp *transactionProducer) endTransaction(result primitive.SendResult, err e
} else {
msgID, _ = primitive.UnmarshalMsgID([]byte(result.MsgID))
}
- // 估计没有反序列化回来
+
brokerAddr := tp.producer.options.Namesrv.FindBrokerAddrByName(result.MessageQueue.BrokerName)
requestHeader := &internal.EndTransactionRequestHeader{
TransactionId: result.TransactionID,