提交 13eeab85 编写于 作者: H Hu Zongtang 提交者: dinglei

[ISSUE #762]fix defaultAsyncSenderExecutor not shutdown when...

 [ISSUE #762]fix defaultAsyncSenderExecutor not shutdown when DefaultMQProducerImpl shutdown. (#880)

[ISSUE #762 ]fix defaultAsyncSenderExecutor not shutdown when DefaultMQProducerImpl shutdown.
上级 bd2e13b5
...@@ -236,6 +236,7 @@ public class DefaultMQProducerImpl implements MQProducerInner { ...@@ -236,6 +236,7 @@ public class DefaultMQProducerImpl implements MQProducerInner {
break; break;
case RUNNING: case RUNNING:
this.mQClientFactory.unregisterProducer(this.defaultMQProducer.getProducerGroup()); this.mQClientFactory.unregisterProducer(this.defaultMQProducer.getProducerGroup());
this.defaultAsyncSenderExecutor.shutdown();
if (shutdownFactory) { if (shutdownFactory) {
this.mQClientFactory.shutdown(); this.mQClientFactory.shutdown();
} }
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册