wip:提交nsq配置

main.go

@@ -22,7 +22,7 @@ func init() {
 func nsqWork() {
 	// Instantiate a consumer that will subscribe to the provided channel.
 	config := nsq.NewConfig()
-	consumer, err := nsq.NewConsumer("jy_event", gcfg.Instance().MustGet(gctx.New(), "nsq.channel", "event").String(), config)
+	consumer, err := nsq.NewConsumer(gcfg.Instance().MustGet(gctx.New(), "nsq.topic", "jy_event").String(), gcfg.Instance().MustGet(gctx.New(), "nsq.channel", "event").String(), config)
 	if err != nil {
 		log.Fatal(err)
 	}