diff --git a/mallinkMQConsumer/src/main/java/com/iformall/mq/impl/AliyunRocketMqConsumer.java b/mallinkMQConsumer/src/main/java/com/iformall/mq/impl/AliyunRocketMqConsumer.java index f14a28f11..42919ce9c 100644 --- a/mallinkMQConsumer/src/main/java/com/iformall/mq/impl/AliyunRocketMqConsumer.java +++ b/mallinkMQConsumer/src/main/java/com/iformall/mq/impl/AliyunRocketMqConsumer.java @@ -19,6 +19,7 @@ import com.aliyun.openservices.ons.api.bean.ConsumerBean; import com.iformall.enums.EnumMsgMqTopic; import com.iformall.mq.MQConfig; import com.iformall.mq.MqBaseConsumer; +import com.iformall.utils.JsonUtil; import lombok.extern.slf4j.Slf4j; @@ -67,7 +68,7 @@ public class AliyunRocketMqConsumer extends MqBaseConsumer { }); consumer.start(); - log.info(" aliyunrocketMq consumer start success!"); + log.info(" aliyunrocketMq consumer start success! "+JsonUtil.obj2Json(consumer)); } } 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 43a32d10d..63c4e3788 100644 --- a/mallinkService/src/main/java/com/iformall/mq/impl/AliyunRocketMqMessageProducer.java +++ b/mallinkService/src/main/java/com/iformall/mq/impl/AliyunRocketMqMessageProducer.java @@ -73,6 +73,7 @@ public class AliyunRocketMqMessageProducer implements MqBaseProducer { @Override public void sendMessage(BaseMsg data, String topic, String tags, String keys) { + log.info("aliyunrocketmq producer info :"+JsonUtil.obj2Json(producer)); //循环发送消息 Message msg = new Message( // // Message 所属的 Topic