Merge pull request #3689 from XiaoyiPeng/wrong_method_comment_about_transaction_msg

francisoliverlee · web-flow · commit a7b59037ed3c · 2022-01-06T20:35:36.000+08:00
[ISSUE #3687] Fix wrong method comment about transaction message.
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
@@ -303,13 +303,13 @@ private TopicConfig selectTopicConfig(String topic) {
      * 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;
     }
