提交 55d66ff4 编写于 作者: C coder-zzzz

fix #1957

DefaultMQProducer didn't shutdown completely
上级 d1b4e47c
...@@ -853,6 +853,7 @@ public class MQClientInstance { ...@@ -853,6 +853,7 @@ public class MQClientInstance {
this.scheduledExecutorService.shutdown(); this.scheduledExecutorService.shutdown();
this.mQClientAPIImpl.shutdown(); this.mQClientAPIImpl.shutdown();
this.rebalanceService.shutdown(); this.rebalanceService.shutdown();
this.defaultMQProducer.shutdown();
if (this.datagramSocket != null) { if (this.datagramSocket != null) {
this.datagramSocket.close(); this.datagramSocket.close();
......
...@@ -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.
先完成此消息的编辑!
想要评论请 注册