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();