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 42919ce9c..77827c01e 100644 --- a/mallinkMQConsumer/src/main/java/com/iformall/mq/impl/AliyunRocketMqConsumer.java +++ b/mallinkMQConsumer/src/main/java/com/iformall/mq/impl/AliyunRocketMqConsumer.java @@ -8,6 +8,7 @@ import org.springframework.beans.factory.annotation.Value; import org.springframework.context.annotation.Profile; import org.springframework.stereotype.Service; +import com.alibaba.fastjson.JSON; import com.aliyun.openservices.ons.api.Action; import com.aliyun.openservices.ons.api.ConsumeContext; import com.aliyun.openservices.ons.api.Consumer; @@ -68,7 +69,7 @@ public class AliyunRocketMqConsumer extends MqBaseConsumer { }); consumer.start(); - log.info(" aliyunrocketMq consumer start success! "+JsonUtil.obj2Json(consumer)); + log.info(" aliyunrocketMq consumer start success! "+JSON.toJSONString(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 cf52006ee..9ef3d3c11 100644 --- a/mallinkService/src/main/java/com/iformall/mq/impl/AliyunRocketMqMessageProducer.java +++ b/mallinkService/src/main/java/com/iformall/mq/impl/AliyunRocketMqMessageProducer.java @@ -11,6 +11,7 @@ import org.springframework.beans.factory.annotation.Value; import org.springframework.context.annotation.Profile; import org.springframework.stereotype.Service; +import com.alibaba.fastjson.JSON; import com.aliyun.openservices.ons.api.Message; import com.aliyun.openservices.ons.api.ONSFactory; import com.aliyun.openservices.ons.api.Producer; @@ -68,6 +69,7 @@ public class AliyunRocketMqMessageProducer implements MqBaseProducer { producer = ONSFactory.createProducer(properties); // 在发送消息前,必须调用 start 方法来启动 Producer,只需调用一次即可 producer.start(); + log.info("aliyunrocketmq producer info :"+JSON.toJSONString(producer)); } @Override @@ -75,8 +77,6 @@ public class AliyunRocketMqMessageProducer implements MqBaseProducer { if (producer.isClosed()) { producer.start(); } - - log.info("aliyunrocketmq producer info :"+JsonUtil.obj2Json(producer)); //循环发送消息 Message msg = new Message( // // Message 所属的 Topic