未验证 提交 af077052 编写于 作者: R rongtong 提交者: GitHub

Merge pull request #1958 from coder-zzzz/apache_bugfix/#1957_DefaultProducer_Timer_didn't_cancle

[ISSUE 1950] fix DefaultMQProducer didn't shutdown completely
...@@ -258,7 +258,7 @@ public class DefaultMQProducerImpl implements MQProducerInner { ...@@ -258,7 +258,7 @@ public class DefaultMQProducerImpl implements MQProducerInner {
if (shutdownFactory) { if (shutdownFactory) {
this.mQClientFactory.shutdown(); this.mQClientFactory.shutdown();
} }
this.timer.cancel();
log.info("the producer [{}] shutdown OK", this.defaultMQProducer.getProducerGroup()); log.info("the producer [{}] shutdown OK", this.defaultMQProducer.getProducerGroup());
this.serviceState = ServiceState.SHUTDOWN_ALREADY; this.serviceState = ServiceState.SHUTDOWN_ALREADY;
break; break;
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册