diff --git a/broker/src/main/java/org/apache/rocketmq/broker/pop/PopConsumerService.java b/broker/src/main/java/org/apache/rocketmq/broker/pop/PopConsumerService.java index a1356c28474..59ca7a0fff8 100644 --- a/broker/src/main/java/org/apache/rocketmq/broker/pop/PopConsumerService.java +++ b/broker/src/main/java/org/apache/rocketmq/broker/pop/PopConsumerService.java @@ -402,17 +402,17 @@ public CompletableFuture popAsync(String clientHost, long po } else { getMessageFuture = this.getMessageFromTopicAsync(getMessageFuture, clientHost, groupId, topicId, requestCount, batchSize, filter, PopConsumerRecord.RetryType.NORMAL_TOPIC); + } - if (!fifo && !preferRetry) { - if (brokerConfig.isRetrieveMessageFromPopRetryTopicV1()) { - getMessageFuture = this.getMessageFromTopicAsync(getMessageFuture, clientHost, groupId, - retryTopicV1, requestCount, batchSize, filter, PopConsumerRecord.RetryType.RETRY_TOPIC_V1); - } + if (!fifo && !preferRetry) { + if (brokerConfig.isRetrieveMessageFromPopRetryTopicV1()) { + getMessageFuture = this.getMessageFromTopicAsync(getMessageFuture, clientHost, groupId, + retryTopicV1, requestCount, batchSize, filter, PopConsumerRecord.RetryType.RETRY_TOPIC_V1); + } - if (brokerConfig.isEnableRetryTopicV2()) { - getMessageFuture = this.getMessageFromTopicAsync(getMessageFuture, clientHost, groupId, - retryTopicV2, requestCount, batchSize, filter, PopConsumerRecord.RetryType.RETRY_TOPIC_V2); - } + if (brokerConfig.isEnableRetryTopicV2()) { + getMessageFuture = this.getMessageFromTopicAsync(getMessageFuture, clientHost, groupId, + retryTopicV2, requestCount, batchSize, filter, PopConsumerRecord.RetryType.RETRY_TOPIC_V2); } }