Avoid calling ConsumerImpl::redeliverMessages() when message list is …

…empty (apache#6480)
AlphaWang · Mar 5, 2020 · 6604f54 · 6604f54
1 parent 17f71d3
commit 6604f54
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/pulsar-client-cpp/lib/NegativeAcksTracker.cc b/pulsar-client-cpp/lib/NegativeAcksTracker.cc
@@ -74,7 +74,9 @@ void NegativeAcksTracker::handleTimer(const boost::system::error_code &ec) {
         }
     }
 
-    consumer_.redeliverMessages(messagesToRedeliver);
+    if (!messagesToRedeliver.empty()) {
+        consumer_.redeliverMessages(messagesToRedeliver);
+    }
     scheduleTimer();
 }