rocketmq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ifplu...@apache.org
Subject [rocketmq-client-cpp] 03/04: fix: MQClientAPIImpl::getMaxOffset
Date Sun, 28 Mar 2021 07:48:13 GMT
This is an automated email from the ASF dual-hosted git repository.

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

commit f622c31bfd7a97188cfd2b620b32e6ef6edaa88a
Author: James Yin <ywhjames@hotmail.com>
AuthorDate: Sun Mar 28 15:02:49 2021 +0800

    fix: MQClientAPIImpl::getMaxOffset
---
 src/MQClientAPIImpl.cpp | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/MQClientAPIImpl.cpp b/src/MQClientAPIImpl.cpp
index 6bc5d3e..fe76f13 100644
--- a/src/MQClientAPIImpl.cpp
+++ b/src/MQClientAPIImpl.cpp
@@ -358,7 +358,7 @@ int64_t MQClientAPIImpl::getMaxOffset(const std::string& addr,
   assert(response != nullptr);
   switch (response->code()) {
     case SUCCESS: {
-      auto* responseHeader = response->decodeCommandCustomHeader<GetMaxOffsetResponseHeader>(GET_MAX_OFFSET);
+      auto* responseHeader = response->decodeCommandCustomHeader<GetMaxOffsetResponseHeader>();
       return responseHeader->offset;
     }
     default:

Mime
View raw message