package nsqclient

import (
	"fmt"
	"kingdee-dbapi/config"
)

var nsqClient Producer

const plcTopic = "plcTopic"

func InitNsqClient() error {
	var err error
	nsqClient, err = NewProducer(config.Options.NsqServer)
	if err != nil {
		fmt.Println(err.Error())
	}

	return err
}

func Produce(msg []byte) (err error) {
	if nsqClient == nil {
		err = InitNsqClient()
		if err != nil {
			return err
		}
	}

	if err = nsqClient.Publish(plcTopic, msg); err != nil {
		fmt.Println("Publish error:" + err.Error())
	}

	return
}