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)); //循环发送消息