package mynsq

import (
	"github.com/nsqio/go-nsq"
)

var w *nsq.Producer
var Server string

func InitNsq(server string) error {
	Server = server
	config := nsq.NewConfig()
	s, err := nsq.NewProducer(server, config)
	w = s
	if err != nil {
		return err
	}
	return err
}

func Send(topic string, msg []byte) error {
	err := w.Publish(topic, msg)
	if err != nil {
		return err
	}
	return err
}