增加topic日志

notify/message.go

@@ -18,7 +18,7 @@ const (
 	//通知下游topic
 	MsgSenderTopic = "messageSenders"
 	//云仓消息topic
-	MsgCloudTopic = "shopApi"
+	MsgCloudTopic = "newShopApi"
 	//通知消息系统topic
 	NotifyTopic = "notifyMessage"
 

notify/producer.go

@@ -38,7 +38,7 @@ func InitProducer(config *NsqConfig) *NsqProducer {
 //发布消息
 func (p *NsqProducer) Publish(topic string, message string) error {
 
-	logs.Info("topic",message)
+	logs.Info("topic","topic:%v,message:%v",topic,message)
 
 	var err error
 	if p.producer != nil {