ZingBug opened a new pull request #2273:
URL: https://github.com/apache/rocketmq/pull/2273


   提交主要在修改函数名的英文单词拼写错误。
   
   
第一个修改为org.apache.rocketmq.client.impl.consumer.PullAPIWrapper#computePullFromWhichFilterServer函数,该函数为private类型,不会对用户使用造成影响。
   
   
第二个修改为org.apache.rocketmq.client.impl.consumer.ProcessQueue#makeMessageToConsumeAgain函数,该函数为public类型,其引用位置也一并修改了,用于指定消息的回滚操作。
   
   
第三个修改为org.apache.rocketmq.client.impl.consumer.DefaultMQPushConsumerImpl#pullMessage函数,在从Broker拉取到消息后的回调方法pullCallback.onSuccess()中,NO_NEW_MSG和NO_MATCHED_MSG类型的处理逻辑完全一致,可以合并case。


----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
[email protected]


Reply via email to