From 13eeab85021fe14b5588a58d4f56e2f279ce1305 Mon Sep 17 00:00:00 2001
From: Hu Zongtang <huzongtang@cmss.chinamobile.com>
Date: Thu, 28 Feb 2019 14:38:13 +0800
Subject: [PATCH]  [ISSUE #762]fix defaultAsyncSenderExecutor not shutdown when
 DefaultMQProducerImpl shutdown. (#880)

[ISSUE #762 ]fix defaultAsyncSenderExecutor not shutdown when DefaultMQProducerImpl shutdown.
---
 .../rocketmq/client/impl/producer/DefaultMQProducerImpl.java     | 1 +
 1 file changed, 1 insertion(+)

diff --git a/client/src/main/java/org/apache/rocketmq/client/impl/producer/DefaultMQProducerImpl.java b/client/src/main/java/org/apache/rocketmq/client/impl/producer/DefaultMQProducerImpl.java
index 90f4f787..6b8fdbd7 100644
--- a/client/src/main/java/org/apache/rocketmq/client/impl/producer/DefaultMQProducerImpl.java
+++ b/client/src/main/java/org/apache/rocketmq/client/impl/producer/DefaultMQProducerImpl.java
@@ -236,6 +236,7 @@ public class DefaultMQProducerImpl implements MQProducerInner {
                 break;
             case RUNNING:
                 this.mQClientFactory.unregisterProducer(this.defaultMQProducer.getProducerGroup());
+                this.defaultAsyncSenderExecutor.shutdown();
                 if (shutdownFactory) {
                     this.mQClientFactory.shutdown();
                 }
-- 
GitLab