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
|
}
|
