Revert "[Bug] Fix lookupRequestSemaphore leak when topic not found vi…

…a http protocol"
pengxiangrui127 · Nov 30, 2023 · a30e6bc · a30e6bc
1 parent 752a9c9
commit a30e6bc
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/MultiTopicsConsumerImpl.java b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/MultiTopicsConsumerImpl.java
@@ -475,10 +475,10 @@ protected CompletableFuture<Message<T>> internalReceiveAsync() {
             } else {
                 decreaseIncomingMessageSize(message);
                 checkState(message instanceof TopicMessageImpl);
-                unAckedMessageTracker.add(message.getMessageId(), message.getRedeliveryCount());                
+                unAckedMessageTracker.add(message.getMessageId(), message.getRedeliveryCount());
+                resumeReceivingFromPausedConsumersIfNeeded();
                 result.complete(message);
             }
-            resumeReceivingFromPausedConsumersIfNeeded();
         });
         return result;
     }