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_;