diff --git a/conn.go b/conn.go index fb5becb..1a1493b 100644 --- a/conn.go +++ b/conn.go @@ -52,7 +52,7 @@ func Conn(group string, resolver []string) { func SendMsg(ctx context.Context, topic, tag string, message []byte) (*primitive.SendResult, error) { if MqPool == nil { - return &res, errors.New("Mq未链接") + return nil, errors.New("Mq未链接") } msg := primitive.NewMessage(topic, message) msg.WithTag(tag)