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 7bccbfc  [ISSUE #286] Add null pointer check before push consumer 
shutdown. (#287)
7bccbfc is described below

commit 7bccbfcb7d3db5dbd57f4b7d10252e763dcaf9c5
Author: dinglei <[email protected]>
AuthorDate: Wed Mar 25 10:59:55 2020 +0800

    [ISSUE #286] Add null pointer check before push consumer shutdown. (#287)
    
    * Add null pointer check before push consumer shutdown.
---
 src/consumer/DefaultMQPushConsumerImpl.cpp | 9 +++++++--
 1 file changed, 7 insertions(+), 2 deletions(-)

diff --git a/src/consumer/DefaultMQPushConsumerImpl.cpp 
b/src/consumer/DefaultMQPushConsumerImpl.cpp
index 98ac401..40dc291 100644
--- a/src/consumer/DefaultMQPushConsumerImpl.cpp
+++ b/src/consumer/DefaultMQPushConsumerImpl.cpp
@@ -1112,8 +1112,13 @@ void 
DefaultMQPushConsumerImpl::createMessageTraceInnerProducer() {
   m_DefaultMQProducerImpl->start(false);
 }
 void DefaultMQPushConsumerImpl::shutdownMessageTraceInnerProducer() {
-  LOG_INFO("Shutdown Message Trace Inner Producer In Consumer.");
-  m_DefaultMQProducerImpl->shutdown(false);
+  if (!getMessageTrace()) {
+    return;
+  }
+  if (m_DefaultMQProducerImpl) {
+    LOG_INFO("Shutdown Message Trace Inner Producer In Consumer.");
+    m_DefaultMQProducerImpl->shutdown(false);
+  }
 }
 bool DefaultMQPushConsumerImpl::hasConsumeMessageHook() {
   return !m_consumeMessageHookList.empty();

Reply via email to