[ISSUE apache#3687] Fix wrong method comment about transaction message.

carlvine500 · Dec 31, 2021 · 0afc8f7 · 0afc8f7
1 parent 43e91f8
commit 0afc8f7
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/...rc/main/java/org/apache/rocketmq/broker/transaction/queue/TransactionalMessageBridge.java b/...rc/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;
     }