|
@@ -49,7 +49,7 @@ func (n *NsqInfo) NsqPushInfo() error {
|
|
|
if err != nil {
|
|
if err != nil {
|
|
|
return fmt.Errorf(err.Error())
|
|
return fmt.Errorf(err.Error())
|
|
|
}
|
|
}
|
|
|
- log.Println(p, "--P--", err)
|
|
|
|
|
|
|
+ log.Println("NSQ:", p, err)
|
|
|
m := &n.NsqMsg
|
|
m := &n.NsqMsg
|
|
|
bs, _ := json.Marshal(m)
|
|
bs, _ := json.Marshal(m)
|
|
|
err = p.Publish(bs)
|
|
err = p.Publish(bs)
|
