[rocketmq] branch develop updated: [ISSUE #3687] Fix wrong method comment about transaction message.

[tigerlee]

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

tigerlee pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git


The following commit(s) were added to refs/heads/develop by this push:
     new 92bf68c  [ISSUE #3687] Fix wrong method comment about transaction 
message.
     new a7b5903  Merge pull request #3689 from 
XiaoyiPeng/wrong_method_comment_about_transaction_msg
92bf68c is described below

commit 92bf68cb77ed59bb659d3d93e3d7c078a87571dd
Author: XiaoyiPeng <644120...@qq.com>
AuthorDate: Fri Dec 31 17:23:26 2021 +0800

    [ISSUE #3687] Fix wrong method comment about transaction message.
---
 .../broker/transaction/queue/TransactionalMessageBridge.java      | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git 
a/broker/src/main/java/org/apache/rocketmq/broker/transaction/queue/TransactionalMessageBridge.java
 
b/broker/src/main/java/org/apache/rocketmq/broker/transaction/queue/TransactionalMessageBridge.java
index 012b9de..9d0152d 100644
--- 
a/broker/src/main/java/org/apache/rocketmq/broker/transaction/queue/TransactionalMessageBridge.java
+++ 
b/broker/src/main/java/org/apache/rocketmq/broker/transaction/queue/TransactionalMessageBridge.java
@@ -303,13 +303,13 @@ public class TransactionalMessageBridge {
      * Use this function while transaction msg is committed or rollback write 
a flag 'd' to operation queue for the
      * msg's offset
      *
-     * @param messageExt Op message
-     * @param messageQueue Op message queue
+     * @param prepareMessage Half message
+     * @param messageQueue Half message queue
      * @return This method will always return true.
      */
-    private boolean addRemoveTagInTransactionOp(MessageExt messageExt, 
MessageQueue messageQueue) {
+    private boolean addRemoveTagInTransactionOp(MessageExt prepareMessage, 
MessageQueue messageQueue) {
         Message message = new Message(TransactionalMessageUtil.buildOpTopic(), 
TransactionalMessageUtil.REMOVETAG,
-            
String.valueOf(messageExt.getQueueOffset()).getBytes(TransactionalMessageUtil.charset));
+            
String.valueOf(prepareMessage.getQueueOffset()).getBytes(TransactionalMessageUtil.charset));
         writeOp(message, messageQueue);
         return true;
     }