From b33b2a198479a84fb8d15ce349a61dde588d0557 Mon Sep 17 00:00:00 2001
From: sschepens <sebastian.schepens@mercadolibre.com>
Date: Mon, 24 Oct 2016 16:49:36 -0300
Subject: [PATCH] Partitioned numMessagesInQueue should count it's incoming
 messages (#78)

---
 .../com/yahoo/pulsar/client/impl/PartitionedConsumerImpl.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/pulsar-client/src/main/java/com/yahoo/pulsar/client/impl/PartitionedConsumerImpl.java b/pulsar-client/src/main/java/com/yahoo/pulsar/client/impl/PartitionedConsumerImpl.java
index 628b4ac85f4..e13a5169b13 100644
--- a/pulsar-client/src/main/java/com/yahoo/pulsar/client/impl/PartitionedConsumerImpl.java
+++ b/pulsar-client/src/main/java/com/yahoo/pulsar/client/impl/PartitionedConsumerImpl.java
@@ -405,7 +405,7 @@ public class PartitionedConsumerImpl extends ConsumerBase {
 
     @Override
     public int numMessagesInQueue() {
-        return consumers.stream().mapToInt(ConsumerImpl::numMessagesInQueue).sum();
+        return incomingMessages.size() + consumers.stream().mapToInt(ConsumerImpl::numMessagesInQueue).sum();
     }
 
     @Override
-- 
GitLab