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

dockerzhang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-tubemq.git


The following commit(s) were added to refs/heads/master by this push:
     new 530eff9  [TUBEMQ-418] C++ SDK function SetMaxPartCheckPeriodMs() can't 
work (#322)
530eff9 is described below

commit 530eff9f2b36c5d1ccae183dfcb28a7e4ef5e434
Author: gosonzhang <[email protected]>
AuthorDate: Sun Nov 22 09:21:48 2020 +0800

    [TUBEMQ-418] C++ SDK function SetMaxPartCheckPeriodMs() can't work (#322)
    
    Co-authored-by: gosonzhang <[email protected]>
---
 tubemq-client-twins/tubemq-client-cpp/src/tubemq_config.cc | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/tubemq-client-twins/tubemq-client-cpp/src/tubemq_config.cc 
b/tubemq-client-twins/tubemq-client-cpp/src/tubemq_config.cc
index fac11b8..877b7f1 100644
--- a/tubemq-client-twins/tubemq-client-cpp/src/tubemq_config.cc
+++ b/tubemq-client-twins/tubemq-client-cpp/src/tubemq_config.cc
@@ -251,6 +251,8 @@ ConsumerConfig& ConsumerConfig::operator=(const 
ConsumerConfig& target) {
     part_offset_map_ = target.part_offset_map_;
     consume_position_ = target.consume_position_;
     max_subinfo_report_intvl_ = target.max_subinfo_report_intvl_;
+    max_part_check_period_ms_ = target.max_part_check_period_ms_;
+    part_check_slice_ms_ = target.part_check_slice_ms_;
     msg_notfound_wait_period_ms_ = target.msg_notfound_wait_period_ms_;
     is_rollback_if_confirm_timout_ = target.is_rollback_if_confirm_timout_;
     reb_confirm_wait_period_ms_ = target.reb_confirm_wait_period_ms_;

Reply via email to