[ISSUE apache#762]fix defaultAsyncSenderExecutor not shutdown when D…

…efaultMQProducerImpl shutdown. (apache#880) [ISSUE apache#762 ]fix defaultAsyncSenderExecutor not shutdown when DefaultMQProducerImpl shutdown.
JiaMingLiu93 · Feb 28, 2019 · 22b0171 · 22b0171
1 parent 2a474fd
commit 22b0171
Showing 1 changed file with 1 addition and 0 deletions.
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
@@ -236,6 +236,7 @@ public void shutdown(final boolean shutdownFactory) {
                 break;
             case RUNNING:
                 this.mQClientFactory.unregisterProducer(this.defaultMQProducer.getProducerGroup());
+                this.defaultAsyncSenderExecutor.shutdown();
                 if (shutdownFactory) {
                     this.mQClientFactory.shutdown();
                 }