File tree Expand file tree Collapse file tree 1 file changed +4
-4
lines changed
broker/src/main/java/org/apache/rocketmq/broker/transaction/queue Expand file tree Collapse file tree 1 file changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -303,13 +303,13 @@ private TopicConfig selectTopicConfig(String topic) {
303
303
* Use this function while transaction msg is committed or rollback write a flag 'd' to operation queue for the
304
304
* msg's offset
305
305
*
306
- * @param messageExt Op message
307
- * @param messageQueue Op message queue
306
+ * @param prepareMessage Half message
307
+ * @param messageQueue Half message queue
308
308
* @return This method will always return true.
309
309
*/
310
- private boolean addRemoveTagInTransactionOp (MessageExt messageExt , MessageQueue messageQueue ) {
310
+ private boolean addRemoveTagInTransactionOp (MessageExt prepareMessage , MessageQueue messageQueue ) {
311
311
Message message = new Message (TransactionalMessageUtil .buildOpTopic (), TransactionalMessageUtil .REMOVETAG ,
312
- String .valueOf (messageExt .getQueueOffset ()).getBytes (TransactionalMessageUtil .charset ));
312
+ String .valueOf (prepareMessage .getQueueOffset ()).getBytes (TransactionalMessageUtil .charset ));
313
313
writeOp (message , messageQueue );
314
314
return true ;
315
315
}
You can’t perform that action at this time.
0 commit comments