Просмотр исходного кода

add aliyun rocketmq log

release_toaliyun_real
xiaohanzi 6 лет назад
Родитель
Сommit
604d5fd8c8
2 измененных файлов: 3 добавлений и 1 удалений
  1. +2
    -1
      mallinkMQConsumer/src/main/java/com/iformall/mq/impl/AliyunRocketMqConsumer.java
  2. +1
    -0
      mallinkService/src/main/java/com/iformall/mq/impl/AliyunRocketMqMessageProducer.java

+ 2
- 1
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.enums.EnumMsgMqTopic;
import com.iformall.mq.MQConfig; import com.iformall.mq.MQConfig;
import com.iformall.mq.MqBaseConsumer; import com.iformall.mq.MqBaseConsumer;
import com.iformall.utils.JsonUtil;


import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;


@@ -67,7 +68,7 @@ public class AliyunRocketMqConsumer extends MqBaseConsumer {
}); });
consumer.start(); consumer.start();
log.info(" aliyunrocketMq consumer start success!");
log.info(" aliyunrocketMq consumer start success! "+JsonUtil.obj2Json(consumer));
} }
} }

+ 1
- 0
mallinkService/src/main/java/com/iformall/mq/impl/AliyunRocketMqMessageProducer.java Просмотреть файл

@@ -73,6 +73,7 @@ public class AliyunRocketMqMessageProducer implements MqBaseProducer {
@Override @Override
public void sendMessage(BaseMsg data, String topic, String tags, String keys) { public void sendMessage(BaseMsg data, String topic, String tags, String keys) {
log.info("aliyunrocketmq producer info :"+JsonUtil.obj2Json(producer));
//循环发送消息 //循环发送消息
Message msg = new Message( // Message msg = new Message( //
// Message 所属的 Topic // Message 所属的 Topic


Загрузка…
Отмена
Сохранить