nsq/nsq.go @@ -41,6 +41,7 @@ constvar.NsqTopicApsProcessParams, constvar.NsqTopicDeviceUpdate, constvar.NsqTopicPullDataResponse, constvar.NsqTopicSendDashboardData, } for _, t := range topics { topic := fmt.Sprintf(t, conf.Conf.NsqConf.NodeId)
