|
|
@@ -100,6 +100,7 @@ func (l *PublishInfoLogic) PublishInfo(in *consumerinfo.PublishInfoReq) (*consum
|
|
|
if in.Attach != "" && in.Attach != "{}" {
|
|
|
appendInfo["attach"] = mc.StringToMap(in.Attach)
|
|
|
}
|
|
|
+ log.Println("发送nsq敏感词信息", model.NsqConfig, appendInfo)
|
|
|
nsq, err := util.NewNsqInfo(model.NsqConfig.Ip, model.NsqConfig.Topic, mc.InterfaceToStr(id), "1", mc.InterfaceToStr(in.MsgType), false, appendInfo)
|
|
|
if err != nil || nsq.NsqPushInfo() != nil {
|
|
|
log.Println("信息发布失败nsq++++++++++++", model.NsqConfig, appendInfo)
|
