package ipc

import (
	"serfNode/config"
	"serfNode/logger"

	"basic.com/aps/nsqclient.git"
)

var nsqClient nsqclient.Producer

const plcTopic = "plcTopic"

func InitNsqClient() error {
	var err error
	nsqClient, err = nsqclient.NewProducer(config.NsqConf.ServerAddr)
	if err != nil {
		logger.Error(err)
	}

	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 {
		logger.Error("Publish error:" + err.Error())
	}

	return
}