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