This is an automated email from the ASF dual-hosted git repository. zhouxzhan pushed a commit to branch develop in repository https://gitbox.apache.org/repos/asf/rocketmq.git
commit 7fc327eb90d7cbd2509cf89f342b7076b90533db Author: zhouxiang <[email protected]> AuthorDate: Tue Jan 10 19:40:22 2023 +0800 fix annotation --- .../org/apache/rocketmq/broker/processor/NotificationProcessor.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/broker/src/main/java/org/apache/rocketmq/broker/processor/NotificationProcessor.java b/broker/src/main/java/org/apache/rocketmq/broker/processor/NotificationProcessor.java index b5e611a98..332843b9f 100644 --- a/broker/src/main/java/org/apache/rocketmq/broker/processor/NotificationProcessor.java +++ b/broker/src/main/java/org/apache/rocketmq/broker/processor/NotificationProcessor.java @@ -250,7 +250,7 @@ public class NotificationProcessor implements NettyRequestProcessor { int queueId = requestHeader.getQueueId(); hasMsg = hasMsgFromQueue(false, requestHeader, queueId); } - // if it has message, fetch retry again + // if it doesn't have message, fetch retry again if (!needRetry && !hasMsg) { TopicConfig retryTopicConfig = this.brokerController.getTopicConfigManager().selectTopicConfig(KeyBuilder.buildPopRetryTopic(requestHeader.getTopic(), requestHeader.getConsumerGroup()));
