From f117e73d5adde7ddf71359396f4d2e5e4a11d9ed Mon Sep 17 00:00:00 2001 From: lizhimins <707364882@qq.com> Date: Tue, 11 Feb 2025 14:08:40 +0800 Subject: [PATCH] [ISSUE #935] C++ simple consumer should remove destructor (#938) --- cpp/examples/ExampleSimpleConsumer.cpp | 1 + cpp/include/rocketmq/SimpleConsumer.h | 2 -- cpp/source/rocketmq/SimpleConsumer.cpp | 4 ---- 3 files changed, 1 insertion(+), 6 deletions(-) diff --git a/cpp/examples/ExampleSimpleConsumer.cpp b/cpp/examples/ExampleSimpleConsumer.cpp index c28d2e4d7..2d93d2393 100644 --- a/cpp/examples/ExampleSimpleConsumer.cpp +++ b/cpp/examples/ExampleSimpleConsumer.cpp @@ -59,6 +59,7 @@ int main(int argc, char* argv[]) { .withAwaitDuration(std::chrono::seconds(10)) .build(); + // Should use while (true) instead for (int j = 0; j < 30; j++) { std::vector messages; std::error_code ec; diff --git a/cpp/include/rocketmq/SimpleConsumer.h b/cpp/include/rocketmq/SimpleConsumer.h index 0550f73a2..cb489c91c 100644 --- a/cpp/include/rocketmq/SimpleConsumer.h +++ b/cpp/include/rocketmq/SimpleConsumer.h @@ -43,8 +43,6 @@ class SimpleConsumerBuilder; class SimpleConsumer { public: - ~SimpleConsumer(); - static SimpleConsumerBuilder newBuilder(); void subscribe(std::string topic, FilterExpression filter_expression); diff --git a/cpp/source/rocketmq/SimpleConsumer.cpp b/cpp/source/rocketmq/SimpleConsumer.cpp index 5ab92f4b5..2b5e79b08 100644 --- a/cpp/source/rocketmq/SimpleConsumer.cpp +++ b/cpp/source/rocketmq/SimpleConsumer.cpp @@ -33,10 +33,6 @@ SimpleConsumerBuilder SimpleConsumer::newBuilder() { SimpleConsumer::SimpleConsumer(std::string group) : impl_(std::make_shared(group)) { } -SimpleConsumer::~SimpleConsumer() { - impl_->shutdown(); -} - void SimpleConsumer::start() { impl_->start(); }