Merge pull request #1 from pengxiangrui127/pengxiangrui127-patch-1

[improve][client] Update MultiTopicsConsumerImpl.java
pengxiangrui127 · Dec 19, 2022 · 752a9c9 · 752a9c9
2 parents 0b5f31d + bfcbc77
commit 752a9c9
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());
-                resumeReceivingFromPausedConsumersIfNeeded();
+                unAckedMessageTracker.add(message.getMessageId(), message.getRedeliveryCount());                
                 result.complete(message);
             }
+            resumeReceivingFromPausedConsumersIfNeeded();
         });
         return result;
     }