|
@@ -103,7 +103,7 @@ func (l *InfoExamineLogic) InfoExamine(in *manager.InfoExamineReq) (*manager.Inf
|
|
|
} else {
|
|
|
//nsq发布信息
|
|
|
appInfo := common.StructToMapMore(info)
|
|
|
- nsq, err := util.NewNsqInfo(md.NsqConfig.Ip, md.NsqConfig.Topic, in.MsgId, common.InterfaceToStr(info.Type), "2", false, appInfo)
|
|
|
+ nsq, err := util.NewNsqInfo(md.NsqConfig.Ip, md.NsqConfig.Topic, in.MsgId, "2", common.InterfaceToStr(info.Type), false, appInfo)
|
|
|
if err != nil || nsq.NsqPushInfo() != nil {
|
|
|
resp.ErrCode = -1
|
|
|
resp.ErrMsg = "人工审核通过,调用nsq失败"
|