From 74f43b03cde98e80a3d1ce02b9aa5aa5b1b720b2 Mon Sep 17 00:00:00 2001 From: xiaohanzi Date: Wed, 10 Jun 2020 10:08:11 +0800 Subject: [PATCH] fix aliyunrocketmq bug --- .../com/iformall/mq/impl/AliyunRocketMqMessageProducer.java | 3 +++ 1 file changed, 3 insertions(+) diff --git a/mallinkService/src/main/java/com/iformall/mq/impl/AliyunRocketMqMessageProducer.java b/mallinkService/src/main/java/com/iformall/mq/impl/AliyunRocketMqMessageProducer.java index 63c4e3788..cf52006ee 100644 --- a/mallinkService/src/main/java/com/iformall/mq/impl/AliyunRocketMqMessageProducer.java +++ b/mallinkService/src/main/java/com/iformall/mq/impl/AliyunRocketMqMessageProducer.java @@ -72,6 +72,9 @@ public class AliyunRocketMqMessageProducer implements MqBaseProducer { @Override public void sendMessage(BaseMsg data, String topic, String tags, String keys) { + if (producer.isClosed()) { + producer.start(); + } log.info("aliyunrocketmq producer info :"+JsonUtil.obj2Json(producer)); //循环发送消息