From 8c0d518f8c3424e6204eaf678edf59fde3d76af0 Mon Sep 17 00:00:00 2001 From: hrsakai Date: Thu, 5 Mar 2020 14:41:54 +0900 Subject: [PATCH] Avoid calling ConsumerImpl::redeliverMessages() when message list is empty --- pulsar-client-cpp/lib/NegativeAcksTracker.cc | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/pulsar-client-cpp/lib/NegativeAcksTracker.cc b/pulsar-client-cpp/lib/NegativeAcksTracker.cc index 492e379459393..202c5e48825aa 100644 --- 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(); }