(rocketmq-client-cpp) branch master updated: Fix negtive diff in-some-case (#489)

[dinglei]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new 4ff2c67  Fix negtive diff in-some-case (#489)
4ff2c67 is described below

commit 4ff2c67bf779ea7c12f0caed03ebef075fc7b986
Author: tiger lee <tiger...@apache.org>
AuthorDate: Tue Feb 18 15:00:14 2025 +0800

    Fix negtive diff in-some-case (#489)
    
    * fix negtive diff
    
    * fix negtive diff
    
    ---------
    
    Co-authored-by: tigerweili <tigerwe...@tencent.com>
---
 src/consumer/DefaultMQPushConsumerImpl.cpp | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/src/consumer/DefaultMQPushConsumerImpl.cpp 
b/src/consumer/DefaultMQPushConsumerImpl.cpp
index 4a79595..ea087d9 100644
--- a/src/consumer/DefaultMQPushConsumerImpl.cpp
+++ b/src/consumer/DefaultMQPushConsumerImpl.cpp
@@ -96,7 +96,7 @@ class AsyncPullCallback : public PullCallback {
         }
         pullRequest->setNextOffset(result.nextBeginOffset);
 
-        if ((pullRequest->getCacheMsgCount() == 0) && (result.nextBeginOffset 
> 0)) {
+        if ((pullRequest->getCacheMsgCount() == 0) && (result.nextBeginOffset 
>= 0)) {
           m_callbackOwner->updateConsumeOffset(pullRequest->m_messageQueue, 
result.nextBeginOffset);
         }
         if (bProducePullRequest) {
@@ -116,7 +116,7 @@ class AsyncPullCallback : public PullCallback {
         }
         pullRequest->setNextOffset(result.nextBeginOffset);
 
-        if ((pullRequest->getCacheMsgCount() == 0) && (result.nextBeginOffset 
> 0)) {
+        if ((pullRequest->getCacheMsgCount() == 0) && (result.nextBeginOffset 
>= 0)) {
           m_callbackOwner->updateConsumeOffset(pullRequest->m_messageQueue, 
result.nextBeginOffset);
         }
         if (bProducePullRequest) {
@@ -736,7 +736,7 @@ void 
DefaultMQPushConsumerImpl::pullMessage(boost::weak_ptr<PullRequest> pullReq
           break;
         }
         request->setNextOffset(pullResult.nextBeginOffset);
-        if ((request->getCacheMsgCount() == 0) && (pullResult.nextBeginOffset 
> 0)) {
+        if ((request->getCacheMsgCount() == 0) && (pullResult.nextBeginOffset 
>= 0)) {
           updateConsumeOffset(messageQueue, pullResult.nextBeginOffset);
         }
         producePullMsgTask(request);
@@ -750,7 +750,7 @@ void 
DefaultMQPushConsumerImpl::pullMessage(boost::weak_ptr<PullRequest> pullReq
           break;
         }
         request->setNextOffset(pullResult.nextBeginOffset);
-        if ((request->getCacheMsgCount() == 0) && (pullResult.nextBeginOffset 
> 0)) {
+        if ((request->getCacheMsgCount() == 0) && (pullResult.nextBeginOffset 
>= 0)) {
           updateConsumeOffset(messageQueue, pullResult.nextBeginOffset);
         }
         producePullMsgTask(request);