fix:when isPopShouldStop hit， unlock queueLockManager

apache · Aug 29, 2024 · f9ea22f · f9ea22f
1 parent 8859093
commit f9ea22f
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/broker/src/main/java/org/apache/rocketmq/broker/processor/PopMessageProcessor.java b/broker/src/main/java/org/apache/rocketmq/broker/processor/PopMessageProcessor.java
@@ -543,6 +543,7 @@ private CompletableFuture<Long> popMsgFromQueue(String topic, String attemptId,
         if (isPopShouldStop(topic, requestHeader.getConsumerGroup(), queueId)) {
             POP_LOGGER.warn("Too much msgs unacked, then stop poping. topic={}, group={}, queueId={}", topic, requestHeader.getConsumerGroup(), queueId);
             restNum = this.brokerController.getMessageStore().getMaxOffsetInQueue(topic, queueId) - offset + restNum;
+            future.whenComplete((result, throwable) -> queueLockManager.unLock(lockKey));
             future.complete(restNum);
             return future;
         }