[rocketmq-client-cpp] branch main updated: Bugfix: wrong judgement to submit fifo consumption task (#382)

[li...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

lizhanhui pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/rocketmq-client-cpp.git


The following commit(s) were added to refs/heads/main by this push:
     new 88998c2  Bugfix: wrong judgement to submit fifo consumption task (#382)
88998c2 is described below

commit 88998c2f926dc20d46b44aa131e75dc8c53aae85
Author: aaron ai <ya...@gmail.com>
AuthorDate: Mon Oct 25 17:01:36 2021 +0800

    Bugfix: wrong judgement to submit fifo consumption task (#382)
---
 src/main/cpp/rocketmq/ConsumeFifoMessageService.cpp | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/src/main/cpp/rocketmq/ConsumeFifoMessageService.cpp b/src/main/cpp/rocketmq/ConsumeFifoMessageService.cpp
index 10519e7..ebefba6 100644
--- a/src/main/cpp/rocketmq/ConsumeFifoMessageService.cpp
+++ b/src/main/cpp/rocketmq/ConsumeFifoMessageService.cpp
@@ -97,7 +97,8 @@ void ConsumeFifoMessageService::submitConsumeTask(const ProcessQueueWeakPtr& pro
 
   if (process_queue_ptr->bindFifoConsumeTask()) {
     std::vector<MQMessageExt> messages;
-    if (process_queue_ptr->take(consumer->consumeBatchSize(), messages)) {
+    process_queue_ptr->take(consumer->consumeBatchSize(), messages);
+    if (!messages.empty()) {
       assert(1 == messages.size());
       submitConsumeTask0(consumer, process_queue, *messages.begin());
     }